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()