celery: remove deprecated settings warnings (#86725)
gitea/hobo/pipeline/head This commit looks good
Details
gitea/hobo/pipeline/head This commit looks good
Details
This commit is contained in:
parent
4daf3d5137
commit
85f9f2501e
|
@ -16,11 +16,11 @@ def notify_agents(data):
|
|||
}
|
||||
with Celery('hobo', broker=settings.BROKER_URL) as app:
|
||||
app.conf.update(
|
||||
CELERY_TASK_SERIALIZER='json',
|
||||
CELERY_ACCEPT_CONTENT=['json'],
|
||||
CELERY_RESULT_SERIALIZER='json',
|
||||
CELERY_QUEUES=(Broadcast('broadcast_tasks'),),
|
||||
CELERY_EVENT_QUEUE_TTL=10,
|
||||
task_serializer='json',
|
||||
accept_content=['json'],
|
||||
result_serializer='json',
|
||||
task_queues=(Broadcast('broadcast_tasks'),),
|
||||
event_queue_ttl=10,
|
||||
)
|
||||
# see called method in hobo.agent.worker.celery
|
||||
app.send_task(
|
||||
|
|
|
@ -22,10 +22,10 @@ from . import services, settings
|
|||
|
||||
app = Celery('hobo', broker=settings.BROKER_URL)
|
||||
app.conf.update(
|
||||
CELERY_TASK_SERIALIZER='json',
|
||||
CELERY_ACCEPT_CONTENT=['json'],
|
||||
CELERY_RESULT_SERIALIZER='json',
|
||||
CELERY_QUEUES=(Broadcast('broadcast_tasks'),),
|
||||
task_serializer='json',
|
||||
accept_content=['json'],
|
||||
result_serializer='json',
|
||||
task_queues=(Broadcast('broadcast_tasks'),),
|
||||
)
|
||||
|
||||
if hasattr(settings, 'CELERY_SETTINGS'):
|
||||
|
|
|
@ -56,10 +56,10 @@ def notify_agents(sender, **kwargs):
|
|||
tls.MUST_NOTIFY = False
|
||||
with Celery('hobo', broker=settings.BROKER_URL) as app:
|
||||
app.conf.update(
|
||||
CELERY_TASK_SERIALIZER='json',
|
||||
CELERY_ACCEPT_CONTENT=['json'],
|
||||
CELERY_RESULT_SERIALIZER='json',
|
||||
CELERY_QUEUES=(Broadcast('broadcast_tasks'),),
|
||||
task_serializer='json',
|
||||
accept_content=['json'],
|
||||
result_serializer='json',
|
||||
task_queues=(Broadcast('broadcast_tasks'),),
|
||||
)
|
||||
# see called method in hobo.agent.worker.celery
|
||||
app.send_task(
|
||||
|
|
Loading…
Reference in New Issue