Mr *_* T. 5 exception celery celery-task
我有一个团体对象。我不想等到所有任务完成并打印结果。这是我的代码:
tasks = [my_task.s(some_val=val).set(queue='different_q') for val in val_list]
job = group(tasks)
job_result = job.apply_async()
results = job_result.get()
Run Code Online (Sandbox Code Playgroud)
如果一切按预期进行,那么我得到的结果
[val1, val2, val3]
Run Code Online (Sandbox Code Playgroud)
但是,如果其中一个任务抛出异常,则该任务job_result.get()也会抛出异常。我知道chord我可以传播异常,但我找不到正确的方法来传播异常group。
这是想要的结果:
[val1, Exception('some exception'), val3]
Run Code Online (Sandbox Code Playgroud)
并且job_result.get()不会抛出异常。