debug json loading code

Consumer.py

@@ -97,7 +97,13 @@ 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']))
+    token_data = recieved_msg["ht_token_encrypted_dumped"]
+
+    if isinstance(token_data, str):
+        token_data = json.loads(token_data)
+
+    token = decrypt_token_from_json(token_data)
+
     # call the model
     model_answer = model_call(recieved_msg,token)
     # send answer to redis

Queue_Producer.py

@@ -1,6 +1,8 @@
 # Producer
 import pika
 import os
+import json
+
 QUEUE_NAME = os.environ["QUEUE_NAME"] 
 
 
@@ -10,7 +12,7 @@ def send_message(RABBITMQ_CONNECTION,data: dict):
 
     channel.queue_declare(queue=QUEUE_NAME, durable=True)
 
-    message = str(data)
+    message = json.dumps(data) #str(data)
 
     channel.basic_publish(
         exchange='',

app.py

@@ -142,7 +142,7 @@ def get_health():
 def call(request: RequestModel):
     global RABBITMQ_CONNECTION
 
-    data = json.dumps(request.model_dump())
+    data =request.model_dump()
 
     redis_send(
         REDIS_CONN,