python - Celery - 将任务名称分配给组中的任务

Question

我是 celery 组以及并发并行执行任务

for item in response_json:
    job_list.append(some_task.s(item))

job = group(job_list)
result = job.apply_async(queue="queue1")

但是，我想为每个项目任务分配自定义任务名称，以便以后可以撤销该任务。我只想撤销组内的一个任务，而不是整个组。

我知道task_name如果我使用我可以分配，apply_async()但这将适用于整个团队而不是单个任务。

无论如何我可以分配task_name给组内的每个任务吗？

标签： pythoncelerycelery-task