Форум сайта python.su
использую django_celery_beat
command=celery -A administration.tasks worker -Q queue_for_tests –loglevel=info
command=celery -A helper beat -l info –scheduler django_celery_beat.schedulersatabaseScheduler
app = Celery('tasks', backend='rpc', broker=settings.CELERY_BROKER_URL)
app.conf.task_routes = {
'click_click': {'queue': 'queue_for_tests'},
}
@app.task(name='click_click', bind=True, max_retries=10, default_retry_delay=600,
throws=(socket.error))
def click(self):
print('hello world')
Отредактировано freezer (Июль 6, 2020 07:44:50)
Офлайн
вопрос снимается, разобрался
Офлайн