working on queue, finalization

Consumer.py

@@ -27,7 +27,7 @@ redis_password = os.environ["REDIS_PASSWORD"]
 
 
 
-def model_call(request):
+def model_call(request,token):
     # fill with last state 
     try:
         state = json.loads(request['last_state']) 
@@ -38,7 +38,7 @@ def model_call(request):
         }
 
     print(f"MODEL CALL WITH STATE {state} and PROMPT {request['prompt']} and MEMORY {request['memory']} and HT_TOKEN {request['ht_token']} and USER_EMAIL {request['user_email']} and USER_NAME {request['user_name']}")
-    answer = get_response(request['prompt'], request['memory'],request['ht_token'],state,request['user_email'],request['user_name'])
+    answer = get_response(request['prompt'], request['memory'],token,state,request['user_email'],request['user_name'])
     
     print(f"ANSWER {answer}")
     # drop unserlizable keys
@@ -74,7 +74,7 @@ def callback(ch, method, properties, body):
     # simulate processing
     token = decrypt_token_from_json(json.loads(recieved_msg['ht_token_encrypted_dumped']))
     print(f"TYPE {type(recieved_msg)}, CONTENT {recieved_msg} , TOKEN {token}")
-    model_call(recieved_msg)
+    model_call(recieved_msg,token)
 
     # (put your logic here)
     print(f"CONSUMER {consumer_id}:::: Processing done")