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

fix: trying librabbitmq for celery backend!

celery_app/server.py

@@ -7,5 +7,7 @@
 host = rabbit_creds["host"]
 port = rabbit_creds["port"]
 
-app = Celery("celery_app/tasks", broker=f"pyamqp://{user}:{password}@{host}:{port}//")
+app = Celery(
+    "celery_app/tasks", broker=f"librabbitmq://{user}:{password}@{host}:{port}//"
+)
 app.autodiscover_tasks(["celery_app"])

worker.py

@@ -32,11 +32,13 @@ def query_llm(recieved_data: dict[str, Any]):
 
     community_id = fetch_community_id_by_guild_id(guild_id=recieved_input.guild_id)
     logging.info(f"COMMUNITY_ID: {community_id} | Sending job to Celery!")
-    ask_question_auto_search.delay(
+    result = ask_question_auto_search.delay(
         question=user_input,
         community_id=community_id,
         bot_given_info=recieved_data,
     )
+    # releasing memory (maybe?)
+    result.forget()
 
 
 @backoff.on_exception(