擅长:python、mysql、java
<p>使用<code>celery==4.2.1</code>时,我必须使用<code>Celery.register_task()</code>的返回值作为要调用<code>delay()</code>的任务实例:</p>
<pre><code># my_app/tasks.py
import celery
from my_app.celery import app
class MyTask(celery.Task):
def run(self):
[...]
MyTask = app.register_task(MyTask())
</code></pre>
<p>那么使用它:</p>
<pre><code># my_app/app.py
from my_app.tasks import MyTask
[...]
MyTask.delay()
</code></pre>
<p>溶液在<a href="https://github.com/celery/celery/issues/3874#issuecomment-285776060" rel="nofollow noreferrer">Github issue</a>中描述,是<a href="http://docs.celeryproject.org/en/4.0/whatsnew-4.0.html#the-task-base-class-no-longer-automatically-register-tasks" rel="nofollow noreferrer">documented here</a>。</p>
<p>Hth公司,
dtk公司</p>