#python #django #celery
Вопрос:
У меня есть интеграция django по умолчанию из документов celery.
Также только что добавил
@before_task_publish.connect(weak=False)
def before_task_publish_handler(*args, **kwargs):
logger.error(f'Args {args}')
logger.error(f'Kwargs {kwargs}')
Работает в оболочке:
debug_task.задержка()
В pycharm нет регистрации или перехвата точек останова. Я не думаю, что это связано с сельдереем, но я не знаю, как проверить. Что я упускаю?
Комментарии:
1. Мне неясно, в чем вопрос/проблема. Ты звонишь
.delay(), и тогда ничего не происходит? Работает ли ваш работник сельдерея?2. Да, работник сельдерея работает. Я ожидаю, что before_task_publish получит соединение от сельдерея. docs.celeryproject.org/en/stable/userguide/signals.html#basics