在线观看不卡亚洲电影_亚洲妓女99综合网_91青青青亚洲娱乐在线观看_日韩无码高清综合久久

鍍金池/ 問答/Python  網(wǎng)絡(luò)安全/ celery chain執(zhí)行順序錯(cuò)誤?

celery chain執(zhí)行順序錯(cuò)誤?

我們有3個(gè)耗時(shí)任務(wù), 需要串行執(zhí)行, 前一個(gè)任務(wù)結(jié)果作為參數(shù)傳給后一個(gè)任務(wù).

剛好celery的chain可以支持這種需求, 于是我這樣寫:

chain(task1.s({'a':1}), task2.s(), task.s())
chain.apply_async()

但是實(shí)際上運(yùn)行時(shí), 三個(gè)任務(wù)的執(zhí)行順序是 task1--task3--task2

實(shí)在懵逼, 望大神解答~感激不盡!

I run a web server by tornado, and it woke up the tasks by chain.

logging:
2018-07-23 18:34:12,816tid:140228657469056 DEBUG: chain: fetch({}) | callback() | convert() | format()

the other tasks run in celery

logging:
[2018-07-23 18:34:12,816: INFO/MainProcess] Received task: fetch[045acf81-274b-457c-8bb5-6d0248264b76]
[2018-07-23 18:34:17,786: INFO/MainProcess] Received task: format[103b4ffa-57db-4b04-a745-7dfee5786695]
[2018-07-23 18:34:18,227: INFO/MainProcess] Received task: convert[81ddbaf9-37b3-406a-b608-a05affa97f45]
[2018-07-23 18:34:20,942: INFO/MainProcess] Received task: callback[b1ea7c70-db45-4501-9859-7ad22532c38a]

回答
編輯回答
久不遇

原來(lái)是因?yàn)镃elery在兩臺(tái)機(jī)器的版本不一致, 后面更改同版本后,運(yùn)行正常

2018年5月14日 10:50
編輯回答
司令
work_flow = chain(task1.s({'a':1}), task2.s(), task.s())
work_flow()

不需要調(diào)用apply_async，仔細(xì)看看文檔http://docs.celeryproject.org...

2017年6月30日 05:12