command=celery -A administration.tasks worker -Q queue_for_tests –loglevel=info
command=celery -A helper beat -l info –scheduler django_celery_beat.schedulers
atabaseSchedulerapp = 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’