entrouvert
/
hobo
16
0
Fork 0
Code Issues Pull Requests 15 Releases Activity

celery: remove deprecated settings warnings (#86725)
gitea/hobo/pipeline/head This commit looks good Details

This commit is contained in:
Nicolas Roche 2024-02-08 14:29:35 +01:00 committed by Nicolas Roche
parent 5423cdf475
commit 159f93a783
3 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hobo/agent/common/__init__.py
View File

@ -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(

8
hobo/agent/worker/celery.py
View File

@ -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'):

8
hobo/deploy/signals.py
View File

@ -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(