working on queue, finalization

Consumer.py

@@ -39,7 +39,6 @@ def redis_send(user_id,msg_id,answer):
         password=redis_password,
     )
  
-    print(f"STORING ANSWER IN REDIS FOR USER_ID {user_id} AND MSG_ID {msg_id}")
     success = r.set(f'ANSWER_FOR_USER_ID{user_id}_OF_{msg_id}',json.dumps(answer))
     return success
 
@@ -53,7 +52,6 @@ def model_call(request,token):
             "memory": request['memory']
         }
 
-    print(f"MODEL CALL WITH STATE {state} and PROMPT {request['prompt']} and MEMORY {request['memory']} and HT_TOKEN {token} and USER_EMAIL {request['user_email']} and USER_NAME {request['user_name']}")
     answer = get_response(request['prompt'], request['memory'],token,state,request['user_email'],request['user_name'])
     
     # drop unserlizable keys
@@ -66,15 +64,14 @@ def model_call(request,token):
 def process_message(recieved_msg):
     # decrypt token
     token = decrypt_token_from_json(json.loads(recieved_msg['ht_token_encrypted_dumped']))
-    print(f"TYPE {type(recieved_msg)}, CONTENT {recieved_msg} , TOKEN {token}")
     # call the model
     model_answer = model_call(recieved_msg,token)
     # send answer to redis
     user_id = recieved_msg["user_id"]
     msg_id = recieved_msg["msg_id"]
     redis_send_res = redis_send(user_id,msg_id,model_answer)
-    print({"STATUS": redis_send_res , "user_id": user_id, "msg_id": msg_id})
-   
+    print({"STATUS": redis_send_res , "CONSUMER": {consumer_id}}) # add monitoring but still hide user data
+
 
 ##################################################
 # CONSUMER METHODS
@@ -93,7 +90,6 @@ def callback(ch, method, properties, body):
 
     ##### Process Message
     process_message(recieved_msg)
-    print(f"CONSUMER {consumer_id}:::: Processing done")
 
 
     ###### Finalize