我有两个不同的 django 项目说projA
和projB
,每个都有自己的芹菜守护进程在不同的队列上运行,但相同的虚拟主机,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 的日志中看到 taskB 在一秒钟内完成,但 taskA 继续等待结果并在 20 秒后超时
对于后端,我有rabbitmq。