对于Celery > = 3.0,使用taskset被弃用赞成组。
from celery import groupfrom tasks import addjob = group([ add.s(2, 2), add.s(4, 4), add.s(8, 8), add.s(16, 16), add.s(32, 32),])
在后台启动组:
result = job.apply_async()
等待:
result.join()
欢迎分享,转载请注明来源:内存溢出
对于Celery > = 3.0,使用taskset被弃用赞成组。
from celery import groupfrom tasks import addjob = group([ add.s(2, 2), add.s(4, 4), add.s(8, 8), add.s(16, 16), add.s(32, 32),])
在后台启动组:
result = job.apply_async()
等待:
result.join()
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)