Как передать параметры в обратных вызовах on_success () и on_failure () в сельдерее? - PullRequest
Новая
       17

Как передать параметры в обратных вызовах on_success () и on_failure () в сельдерее?

0 голосов
/ 04 июня 2019 
from  my_celery import app
from delete_duplicate import DeleteDuplicate

import celery


class CallbackTask(celery.Task):
    def on_success(self, retval, task_id, args, kwargs):
        print "Task id: ", task_id
        print "retval ", retval     
        print "Args ", args
        print "kwargs: ", kwargs

    def on_failure(self, exc, task_id, args, kwargs, einfo):
        print('{0!r} failed: {1!r}'.format(task_id, exc))   



class Ott(object):
    @app.task(base=CallbackTask())  
    def delete_duplicate_ott():
        print "Inside ott.... "
        DeleteDuplicate().delete_duplicate_ott()
    @app.task(base=CallbackTask())
    def delete_duplicate_noti():
        print "Inside noti.... "
        DeleteDuplicate().delete_duplicate_noti()

Я использовал Обратный вызов в сельдерее для реализации вышеуказанного обратного вызова.

Над кодом работает отлично. Я хочу передать параметры в обратных вызовах on_success () и on_failure () в args или kwargs. Args и Kwargs оба печатают None после успешного выполнения задачи.

Я ищу в Интернете, но не могу найти никакого решения, которое бы выполняло обратный вызов такого типа с использованием наследования (подкласс).

Любая помощь высоко ценится. Спасибо!

...