Celery 任务 on_success 处理程序的 kwargs 始终为空

Question

芹菜版本= 4.3.0

我想要做的就是能够在任务的自定义成功处理程序中访问 celery 任务函数的实际参数（普通参数和关键字）。我能够正确打印出非关键字参数，但关键字参数始终为空。

下面是代码

任务结果处理程序

from celery import Task

class ActionOnCompletion(Task):
    def on_success(self, retval, task_id, args, kwargs):
        print "inside success handler"
        print retval[0] # prints => ["results"]
        print retval[1].get('meta') # prints => this is meta
        print "task function args were"
        print args # prints => (<value_of_arg1 as passed while invoking the task>, <value_of_arg2 as passed while invoking the task>)
        print "keyword args"
        print type(kwargs) # prints => <type 'dict'>
        print kwargs # prints => {} I was expecting {"someKeyWordArg":"randommmm"} to be printed here !
        print kwargs.get('someKeyWordArg') # does not print anything

    def on_failure(self, exc, task_id, args, kwargs, einfo):
        print einfno

实际任务

from celeryConfig.celeryApp import celapp
from celeryConfig.taskResultsHandler import ActionOnCompletion

@celapp.task(base=ActionOnCompletion)
def myTask(arg1, arg2, someKeyWordArg="randommmm"):
    print("starting my task")
    print someKeyWordArg
    time.sleep(5)
    return ["results"], {'meta':"this is meta"}

有人可以帮助我理解上面遗漏了什么以及为什么我能够得到非关键字参数很好但空关键字参数？

现在我有解决方法来完成我的工作，比如在我的任务中仅使用 args 而不是 kwargs 并在 on_success 中访问它们，但我真的很想知道上面出了什么问题。

Answer 1

您的任务签名需要更改为

def on_success(self, retval, task_id, *args, **kwargs):

Answer 2

这有点令人困惑，但正在发生的事情是 celery 没有记录 kwargs，因为它们是默认的 - 它们不是按照你的 args 的方式“传入”的（这是必需的，因为它们是位置性的）。 IOW，celery 不会检查默认 kwargs 的方法签名，它只记录调用 delay （或

apply_async

等）时实际传递的内容。