芹菜动态任务/将芹菜实现隐藏在界面后面

Question

我试图弄清楚如何使用 Celery 实现我的异步作业，而不是将它们绑定到 Celery 实现。

如果我有一个接受要调度的对象（例如可调用对象（或包装可调用对象的对象）：

ITaskManager(Interface):
    def schedule(task):
        #eventually run task

我可能会使用踩踏模块来实现它：

ThreadingTaskManager(object)
    def schedule(task):
        Thread(task).start() # or similar

但似乎这不能用芹菜完成，对吗？

Answer 1

也许一个（尽管相当丑陋）解决方案可能是定义一个芹菜任务，该任务动态加载作为参数传递的任务对象：

@celery.task
def taskrunner(taskname):
    taskModule = __import__(taskname)
    taskModule.run()
CeleryTaskManager(object)
    def schedule(task):
        taskrunner.delay(task.__file__)

from mytask import run
CeleryTaskManager().schedule(run)