代码之家 › 专栏 › 技术社区 › andilabs

@task\u postrun。连接芹菜中的信号并执行另一个任务会导致一些执行的内场循环

celerybeat django-celery celery

andilabs · 技术社区 · 6 年前

我需要以下工作流程为我的芹菜任务。

当taskA成功完成时,我想执行taskB。

我知道有信号 @task_success 但这只返回任务的结果,我需要访问前一个任务的参数。所以我决定编写如下代码:

@app.task
def taskA(arg):
    # not cool, but... https://github.com/celery/celery/issues/3797
    from shopify.tasks import taskA
    taskA(arg)


@task_postrun.connect
def fetch_taskA_success_handler(sender=None, **kwargs):
    from gcp.tasks import taskB
    if kwargs.get('state') == 'SUCCESS':
        taskB.apply_async((kwargs.get('args')[0], ))

问题是 taskB 似乎在一些无休止的循环中执行了很多次,而不是只有一次。

1 回复 | 直到 6 年前

andilabs 6 年前

@app.task
def taskA(arg):
    # not cool, but... https://github.com/celery/celery/issues/3797
    # otherwise it won't added in periodic tasks
    from shopify.tasks import taskA
    return taskA(arg)


@task_postrun.connect
def taskA_success_handler(sender=None, state=None, **kwargs):

    resource_name = kwargs.get('kwargs', {}).get('resource_name')

    if resource_name and state == 'SUCCESS':

        if sender.name == 'shopify.tasks.taskA':
            from gcp.tasks import taskB
            taskB.apply_async(kwargs={
                'resource_name': resource_name
            })

仅供参考:

celery==4.1.0
Django==2.0
django-celery-beat==1.1.0
django-celery-results==1.0.1
flower==0.9.2
amqp==2.2.2

Python 3.6

推荐文章

furang · 在Django模板中将芹菜任务的结果返回给客户端

6 年前

furang · 在Django不能叫芹菜

6 年前

Alexander · Django 2,Celery 4.1 ModuleNotFoundError:没有名为Djancelly的模块

6 年前

andilabs · @task\u postrun。连接芹菜中的信号并执行另一个任务会导致一些执行的内场循环

6 年前

juju · Django芹菜daemonization

7 年前

Saifullah khan · Django Celery仅使用失败的数据集重试当前任务

7 年前

Matt · 芹菜任务未超时

7 年前

user714852 · 为什么将导出DJANGO_SETTINGS_MODULE='myproject.SETTINGS'添加到bashrc不再有效?

10 年前

zeenfaiz · Django和Celery的全局变量

11 年前

Gandalf · 为django安装芹菜

11 年前