()
| 62 | |
| 63 | @pytest.fixture() |
| 64 | def rabbitmq_broker(): |
| 65 | broker = RabbitmqBroker( |
| 66 | host="127.0.0.1", |
| 67 | max_priority=10, |
| 68 | credentials=RABBITMQ_CREDENTIALS, |
| 69 | ) |
| 70 | check_rabbitmq(broker) |
| 71 | broker.emit_after("process_boot") |
| 72 | dramatiq.set_broker(broker) |
| 73 | yield broker |
| 74 | broker.flush_all() |
| 75 | broker.close() |
| 76 | |
| 77 | |
| 78 | @pytest.fixture() |
nothing calls this directly
no test coverage detected