()
| 77 | |
| 78 | @pytest.fixture() |
| 79 | def redis_broker(): |
| 80 | broker = RedisBroker() |
| 81 | check_redis(broker.client) |
| 82 | broker.client.flushall() |
| 83 | broker.emit_after("process_boot") |
| 84 | dramatiq.set_broker(broker) |
| 85 | yield broker |
| 86 | broker.client.flushall() |
| 87 | broker.close() |
| 88 | |
| 89 | |
| 90 | @pytest.fixture() |
nothing calls this directly
no test coverage detected