Update celery_app/utils/fire_event.py

Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
TogetherCrew · Jun 26, 2024 · de9ca16 · de9ca16
1 parent 57d5aca
commit de9ca16
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/celery_app/utils/fire_event.py b/celery_app/utils/fire_event.py
@@ -37,4 +37,7 @@ def job_send(event: str, queue_name: str, content: dict[str, Any]) -> None:
         content=content,
     )
     logging.info("Published to RabbitMQ!")
-    rabbit_mq.connection.close()
+    try:
+        rabbit_mq.connection.close()
+    except Exception as e:
+        logging.error(f"Failed to close RabbitMQ connection: {e}")