TahaFawzyElshrif commited on
Commit
9c20148
·
1 Parent(s): a80f601

working on queue, finalization

Browse files
Files changed (1) hide show
  1. Consumer.py +1 -1
Consumer.py CHANGED
@@ -74,7 +74,7 @@ def callback(ch, method, properties, body):
74
  # simulate processing
75
  token = decrypt_token_from_json(json.loads(recieved_msg['ht_token_encrypted_dumped']))
76
  print(f"TYPE {type(recieved_msg)}, CONTENT {recieved_msg} , TOKEN {token}")
77
- #model_call(recieved_msg)
78
 
79
  # (put your logic here)
80
  print(f"CONSUMER {consumer_id}:::: Processing done")
 
74
  # simulate processing
75
  token = decrypt_token_from_json(json.loads(recieved_msg['ht_token_encrypted_dumped']))
76
  print(f"TYPE {type(recieved_msg)}, CONTENT {recieved_msg} , TOKEN {token}")
77
+ model_call(recieved_msg)
78
 
79
  # (put your logic here)
80
  print(f"CONSUMER {consumer_id}:::: Processing done")