Python-сообщество

freezer · Июль 6, 2020 07:42:38

использую 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')

все работает
только tasks.click.delay() отправляет в ‘queue_for_tests’
а если включить periodic task а админке эту же задачу отправляет в очередь ‘celery’
подскажите как отправить в ‘queue_for_tests’

Отредактировано freezer (Июль 6, 2020 07:44:50)

freezer · Июль 6, 2020 12:10:59

вопрос снимается, разобрался

Python-сообщество

Уведомления

#1 Июль 6, 2020 07:42:38

django_celery_beat

#2 Июль 6, 2020 12:10:59

django_celery_beat

Board footer