|
@@ -572,8 +572,7 @@ copies of tasks to all workers connected to it:
|
|
|
|
|
|
CELERY_QUEUES = (Broadcast('broadcast_tasks'), )
|
|
CELERY_QUEUES = (Broadcast('broadcast_tasks'), )
|
|
|
|
|
|
- CELERY_ROUTES = {'tasks.reload_cache': 'broadcast_tasks'}
|
|
|
|
-
|
|
|
|
|
|
+ CELERY_ROUTES = {'tasks.reload_cache': {'queue': 'broadcast_tasks'}}
|
|
|
|
|
|
Now the ``tasks.reload_tasks`` task will be sent to every
|
|
Now the ``tasks.reload_tasks`` task will be sent to every
|
|
worker consuming from this queue.
|
|
worker consuming from this queue.
|