Что не так с celery_self?

Question

[Павел]

Вот уж не пойму, от чего у меня работает вот так

@celery.task(bind=True)
def task_first():
    pass

И таких тасков у меня много.

Но вдруг решил добавить ещё одну очередь и новый таск

@celery.task(bind=True)
def task_second():
    pass

И на тебе

missing 1 required positional argument: 'celery_self'

И теперь хоть добавляй, хоть Bind=True, хоть Bind=False, хоть вообще без него выдаёт вышеописанную ошибку, но только на новом таске.
Как эт понять?

Answer 1

[Ivan]

По правильному, если уж указали bind=True, то подразумевается что в вашем таске будет использоваться инстанс таска, а значит функция первым аргументом получает self. Очень странно, что у Вас работало по другому, может были декораторы какие?
По докам, работать должно только так

@celery.task(bind=True)
def task_first(self):
    pass


@celery.task()
def task_second():
    pass

Comments

[Павел]

И мне было не ясно почему так.

'run-every-60-seconds': {

            # Name of task to run (see the "Tasks" section below)
            'task': 'appdata.tasks.my_task_without_self,

            # Task interval
            'schedule': timedelta(seconds=60),

            # Task arguments (see the "Tasks" section below)
            # 'args': ()
        },

Но когда убрал 'args': (), то получилось запустить без self.
Если убрать этот таск из шедулера, то ручной запуск успешный. А когда добавляю в шедулер, то и ручной запуск ломается. Т.е. добавление в шедулер как-то влияет на сам таск.

[Ivan]

У Вас на машине определенно магия какая-то творится. Шедулер никик не влияет на вызов таска в ручном режиме