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

---