У меня есть два разных проекта django, скажем, projA
и projB
, каждый из которых имеет свой собственный демон сельдерея, работающий в отдельных очередях, но с одним и тем же vhost, у projA есть задача taskA
, а у projB есть задача taskB
, я пытаюсь запустить taskB
изнутри taskA
, например.
@task(routing_key='taskA')
def taskA(event_id):
# do some work , then call taskB and wait for result
result = send_task('taskB',routing_key='taskB')
res = result.get(timeout=20)
Я вижу в журналах projB, что задача B завершена в течение секунды, но задача A продолжает ждать результата и истекает через 20 секунд.
Для бэкэнда у меня есть rabbitmq.