Celery update changes receiver syntax: episode 2

sergmelikyan · Jul 22, 2017 · 0e97b8e · 0e97b8e
1 parent e6fb58b
commit 0e97b8e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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)