From 0e97b8eb46b9191f557d6fd46019223cc36e7de3 Mon Sep 17 00:00:00 2001 From: Collin Date: Sat, 22 Jul 2017 17:15:32 -0400 Subject: [PATCH] Celery update changes receiver syntax: episode 2 --- rollback_worker.py | 2 +- sync_poll_triggers.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/rollback_worker.py b/rollback_worker.py index 2fb274a99..0ed7d2067 100644 --- a/rollback_worker.py +++ b/rollback_worker.py @@ -18,7 +18,7 @@ class _celeryConfig: celery_app.config_from_object(_celeryConfig()) @worker_shutdown.connect -def celery_shutdown(): +def celery_shutdown(**kwargs): close_connections() @celery_app.task() diff --git a/sync_poll_triggers.py b/sync_poll_triggers.py index 2d19ca5ba..de7d2af19 100644 --- a/sync_poll_triggers.py +++ b/sync_poll_triggers.py @@ -24,7 +24,7 @@ class _celeryConfig: celery_app.config_from_object(_celeryConfig()) @worker_shutdown.connect -def celery_shutdown(): +def celery_shutdown(**kwargs): close_connections() @celery_app.task(acks_late=True)