在和弦中的任务中启动不相关的 Celery 任务

Question

我是 celery 的新手，我无疑错过了显而易见的事情，但是我如何在另一个应该完全独立于 some_other_task 执行的 celery some_other_task 中启动一个 celery some_worker_task？特别是我有一个芹菜和弦

junk = chord((task_create_syslog_records.s(syslog, user, syslog.fileset_id)
              for syslog in syslog_queryset),
             task_create_syslog_records_done_email.si(user, len(syslog_queryset), syslog_queryset[0].fileset_id))()

在其中一个 task_create_syslog_records 中的某些条件下，我需要启动另一个与和弦无关的任务 do_some_stuff。它可以完全独立于和弦运行，并且和弦不需要/不需要它的结果。和弦应该完成并且 task_create_syslog_records_done_email 运行，即使 do_some_stuff 仍在运行。

Answer 1

您可以在现有任务中创建另一个 celery 任务：

@app.task
def do_some_stuff():
    pass

@app.task
def task_create_syslog_records(syslog, user, filset_id):
    # ...    
    if condition_is_matched:
        do_some_stuff.delay()
    # ...
    return result