working on queue, finalization

app.py

@@ -11,7 +11,7 @@ import subprocess
 from Queue_Producer import send_message
 import redis
 from utils import RequestModel, RequestAnswer
-
+from Consumer import redis_send
 
 ##################################################
 # VARIABLES
@@ -79,6 +79,7 @@ def old_call(request: RequestModel):
     
 @app.post("/Message/Send/")
 def call(request: RequestModel): 
+    redis_send(request.user_id,request.msg_id,{"status": "processing"}) 
     return send_message(json.dumps(request.model_dump()))
 
 
@@ -88,7 +89,7 @@ def call(request: RequestAnswer):
     try:
         answer = redis_conn.get(f'ANSWER_FOR_USER_ID{request.user_id}_OF_{request.msg_id}')
         if answer is None:
-            return {"status": "error", "message": "No answer found in Redis."}
+            return {"status": "error"}
         else:
             redis_conn.delete(f'ANSWER_FOR_USER_ID{request.user_id}_OF_{request.msg_id}')  # Clean up after fetching  for memory and better secure as double call is wrong   
             return {"status": "ready", "data": json.loads(answer)}