celery-canvas

0熱度

1回答

芹菜帆布組傳遞參數太多組成任務

我遇到與下面這種芹菜工作流程的一些非常奇怪的行爲鏈： workflow = group( chain(task1.s(), task2.s()), chain(task3.s(), task4.s()), ) 這是在Django的背景下。 當我調用工作流程如下： workflow.apply_async((n,)) ...對於n的任意整數值，在每個鏈（task1和task3

python django celery celery-canvas 2017-08-31

---

1熱度

1回答

使用關鍵字參數調用任務塊

如何使用關鍵字參數塊化任務？例如，此任務： @app.task def add(x, y, multiply=1, unit="GB"): return '%s %s' % ((x + y) * multiply, unit) 我可以像往常一樣使用add.apply_async(args=(1, 2), kwargs={'unit': 'MB'})調用此任務，但是如何組塊它？ 我想

python celery celery-task keyword-argument celery-canvas 2017-02-14

---

0熱度

1回答

使用芹菜畫布，chord（）和chain（group（），task）有什麼區別

我們正在使用Celery實現一個工作流程。首先，我們需要並行運行一些任務，當它們全部完成時，我們需要運行一個任務。 我們似乎可以用弦，或組，鏈條： chord(tasks, task) VS group(tasks) | task 是什麼這兩個之間的確切區別？他們似乎也做同樣的事情。

python celery celery-canvas 2015-07-02

---