bring test celery in line with project

This commit is contained in:
Joel Falknau 2024-09-09 13:59:43 +10:00
parent 271fd8e8c4
commit 4ed1c5b7c4
No known key found for this signature in database

View File

@ -1,4 +1,5 @@
import os import os
from celery import Celery from celery import Celery
# set the default Django settings module for the 'celery' program. # set the default Django settings module for the 'celery' program.
@ -12,6 +13,10 @@ app = Celery('devauth')
# the configuration object to child processes. # the configuration object to child processes.
app.config_from_object('django.conf:settings') app.config_from_object('django.conf:settings')
# Automatically try to establish the connection to the AMQP broker on
# Celery startup if it is unavailable.
app.conf.broker_connection_retry_on_startup = True
# setup priorities ( 0 Highest, 9 Lowest ) # setup priorities ( 0 Highest, 9 Lowest )
app.conf.broker_transport_options = { app.conf.broker_transport_options = {
'priority_steps': list(range(10)), # setup que to have 10 steps 'priority_steps': list(range(10)), # setup que to have 10 steps