subtask = task.s(*myargs, **mykwargs).set(queue=myqueue) mychain = celery.chain(subtask, subtask2, ...) mychain.apply_async() ...
確定! 回上一頁