Spaces:
Sleeping
Sleeping
removed state print
Browse files- Consumer.py +0 -4
Consumer.py
CHANGED
|
@@ -87,7 +87,6 @@ def model_call(request, token):
|
|
| 87 |
|
| 88 |
)
|
| 89 |
|
| 90 |
-
print(response)
|
| 91 |
if "question" in response.keys():
|
| 92 |
return response["question"]
|
| 93 |
elif "report" in response.keys():
|
|
@@ -110,7 +109,6 @@ def process_message(recieved_msg):
|
|
| 110 |
user_id = recieved_msg["user_id"]
|
| 111 |
chat_id = recieved_msg["chat_id"]
|
| 112 |
redis_send_res = redis_send(REDIS_CONN,user_id,chat_id,model_answer)
|
| 113 |
-
print({"STATUS": redis_send_res , "CONSUMER": {consumer_id}}) # add monitoring but still hide user data
|
| 114 |
|
| 115 |
|
| 116 |
##################################################
|
|
@@ -124,8 +122,6 @@ def callback(ch, method, properties, body):
|
|
| 124 |
try:
|
| 125 |
##### Recieve message and process it
|
| 126 |
recieved_msg = json.loads(body.decode())
|
| 127 |
-
print("-------------------------------------------------")
|
| 128 |
-
print(f"MSG AT CONSUMER {consumer_id}" )
|
| 129 |
|
| 130 |
##### Process Message
|
| 131 |
process_message(recieved_msg)
|
|
|
|
| 87 |
|
| 88 |
)
|
| 89 |
|
|
|
|
| 90 |
if "question" in response.keys():
|
| 91 |
return response["question"]
|
| 92 |
elif "report" in response.keys():
|
|
|
|
| 109 |
user_id = recieved_msg["user_id"]
|
| 110 |
chat_id = recieved_msg["chat_id"]
|
| 111 |
redis_send_res = redis_send(REDIS_CONN,user_id,chat_id,model_answer)
|
|
|
|
| 112 |
|
| 113 |
|
| 114 |
##################################################
|
|
|
|
| 122 |
try:
|
| 123 |
##### Recieve message and process it
|
| 124 |
recieved_msg = json.loads(body.decode())
|
|
|
|
|
|
|
| 125 |
|
| 126 |
##### Process Message
|
| 127 |
process_message(recieved_msg)
|