celery的task_success这个signal为什么不起作用了

Question

@celery_app.task(name=u"abc", routing_key="xxx")
def func_abc(a, b, c, d):
    pass
    
@task_success.connect(sender=u"abc")
def on_abc_success(sender, result, **kwargs):
    pass

代码逻辑总体是上面这样。

celery的任务是由ubuntu机器发出，broker为redis，worker运行在windows机器，两机器上的代码是一样的。

现在ubuntu发出任务"abc"，windows机器能正常接收且可以正常完成，但完成之后task_success所装饰的任务并不能得到执行，可能是什么原因呢？

（尝试过将task_success里的sender改为函数对象func_abc，也不行）

Answer 1

解决了吗 楼主 同求