Celery синхронизирует узлы разных очередей в одном запросе

Я использую Celery 4.4.2 и использую различные очереди и узлы на одной машине. Моя цель - разделить и организовать каждый процесс Django Apps. Очереди работают нормально на разных узлах.

Примером заголовка для каждого задания являются:

@shared_task(name = "task1_App1", bind = True, result_extended = True, queue = 'App1')
@shared_task(name = "task1_App2", bind = True, result_extended = True, queue = 'App2')

И я запускаю 2 узла Celery в отдельной подсказке с:

celery -A siteconfig worker-Q App1 -l info -n app1@%h -P gevent
celery -A siteconfig worker-Q App2 -l info -n app2@%h -P gevent

Когда я запускаю задачу в узле app1, она появляется в подсказке узла app2 с сообщением "app1 sync with app2". Я хочу, чтобы каждый узел показывал только свои задачи, без синхронизации с подсказкой другого узла. Какие варианты я могу использовать?

Я использую Win, Python 3.7.8 и Django 2.2.

Вернуться на верх