We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3bf80b2 commit ea28520Copy full SHA for ea28520
src/aap_eda/core/tasking/__init__.py
@@ -176,6 +176,10 @@ def enable_redis_prefix():
176
rq.queue.Queue.redis_queues_keys = f"{redis_prefix}:queues"
177
178
# Worker.
179
+ # Although PUBSUB_CHANNEL_TEMPLATE is defined in rq.command (and we've
180
+ # overridden it there for any new uses) rq.worker, which we've already
181
+ # imported, imports it so we need to override that value as well.
182
+ rq.worker.PUBSUB_CHANNEL_TEMPLATE = rq.command.PUBSUB_CHANNEL_TEMPLATE
183
rq.worker.Worker.redis_worker_namespace_prefix = f"{redis_prefix}:worker:"
184
rq.worker.Worker.redis_workers_keys = f"{redis_prefix}:workers"
185
rq.worker_registration.REDIS_WORKER_KEYS = f"{redis_prefix}:workers"
0 commit comments