Asynchonous子任务

Question

我需要芹菜异步调用子任务对另一个人（另一台机器上）这样的：

#db.py 
@task() 
def query(x,y): 
    ...something 
    return z 

#worker2.py 
@task() 
def main(x,y): 
    result=db.query.async((x,y), queue='db') 
    try: 
     a=result.get(timeout=5) 
    except celery.exceptions.TimeoutError: 
     .... 

但是从工人，当我得到警告： RuntimeWarning：一定不要调用result.get （）在一个任务！

如何从另一个任务调用异步任务？我wont'n使用链，和弦等

Answer 1

，就算你想阻止一个任务等待另一个，所以正确的做法是用chain：

db.py 
@task() 
def query(x, y): 
    ...something 
    return z 

#worker2.py 
@task() 
def main(resultFromQuery, x, y): 
    a = resultFromQuery.get(timeout=5) 
    ... 

res = chain(query.s(x,y), main.s(x,y)); 
res.get()