Merge pull request #76 from TogetherCrew/fix/72-memory-leak

fix: closing rabbitMQ connection!
TogetherCrew · Jun 26, 2024 · 83ff554 · 83ff554
2 parents 361b486 + de9ca16
commit 83ff554
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/celery_app/utils/fire_event.py b/celery_app/utils/fire_event.py
@@ -37,3 +37,7 @@ def job_send(event: str, queue_name: str, content: dict[str, Any]) -> None:
         content=content,
     )
     logging.info("Published to RabbitMQ!")
+    try:
+        rabbit_mq.connection.close()
+    except Exception as e:
+        logging.error(f"Failed to close RabbitMQ connection: {e}")