python - RQ：使用 `@job` 装饰器时的成功和失败处理

Question

我正在使用@job装饰器来定义如下任务：

rqueue = Queue(connection=Redis.from_url(REDIS_URL))

@job(queue=rqueue)
def add(x, y):
    time.sleep(2)
    return x+y

当我称它为add.delay(100, 100). 但我需要为我的工作提供成功和回调处理程序。当我将我的工作定义为@job(queue=rqueue, on_success=my_callback_func)失败并显示一条消息说它得到了一个意外的关键字参数时on_success。

如果我像下面这样将工作排入队列，它会顺利运行：

rqueue.enqueue(add, on_success=my_callback_func)

我还尝试使用函数传递回调处理程序，delay但没有运气。

请帮忙 ！！！