Celery从4.0.2升级至4.2.0后delay调用报错求助

我之前升级Celery的时候也碰到过几乎一模一样的错误，结合你的代码和报错信息，问题主要出在任务装饰器的使用方式和变量命名冲突上，下面给你具体的排查和修复步骤：

1. 修正任务装饰器的使用方式 #

Celery 4.x之后，官方不再推荐直接使用from celery import task这种全局装饰器，而是要求绑定到具体的Celery应用实例。旧的全局装饰器在新版本中会导致任务绑定异常，直接触发shadow_name()相关的错误。

正确的做法是先创建Celery应用实例：

# 首先初始化Celery应用
from celery import Celery

# 替换成你的broker地址，比如redis://localhost:6379/0或者你的RabbitMQ地址
app = Celery('myapp', broker='your_broker_url_here')  

然后用这个实例的task装饰器来定义任务：

@app.task  # 这里用app.task代替原来的@task全局装饰器
def run_mytask(pk):
    print(pk)  # 额外提醒：Celery 4.2.0更适配Python 3，建议把Python 2的print语法改成带括号的形式

2. 避免变量命名冲突 #

你的代码最后一行task = tasks.run_mytask.delay(pk)里，变量名task和你之前导入的@task装饰器重名了，这会干扰任务的正常调用逻辑。建议把这个变量名改成其他名称，比如task_result：

# 如果在同一个模块直接调用
task_result = run_mytask.delay(pk)

# 如果是跨模块导入调用
from your_tasks_module import run_mytask
task_result = run_mytask.delay(pk)

3. 验证任务注册是否正确 #

修改完成后，可以通过Celery命令确认任务是否被正确注册：

# 替换your_app_name为你的Celery应用所在的模块名（比如app在tasks.py里就写tasks）
celery -A your_app_name inspect registered

如果输出里能看到run_mytask，说明任务注册成功，此时再运行代码应该就不会报错了。

错误原因补充 #

Celery 4.x对任务的内部绑定机制做了大幅调整，旧的全局@task装饰器没有正确把任务和应用实例绑定，导致调用delay()时，任务对象的方法调用缺少了必要的实例参数，从而抛出unbound method shadow_name() must be called with run_mytask instance as first argument的错误。

内容的提问来源于stack exchange，提问作者pyCthon