Spaces:
Running
Running
TahaFawzyElshrif commited on
Commit ·
116d809
1
Parent(s): 669e816
debug end
Browse files- Consumer.py +0 -1
- app.py +0 -2
Consumer.py
CHANGED
|
@@ -75,7 +75,6 @@ def model_call(request, token):
|
|
| 75 |
if k in answer:
|
| 76 |
answer[k] = ""
|
| 77 |
|
| 78 |
-
print(answer)
|
| 79 |
return answer
|
| 80 |
|
| 81 |
def process_message(recieved_msg):
|
|
|
|
| 75 |
if k in answer:
|
| 76 |
answer[k] = ""
|
| 77 |
|
|
|
|
| 78 |
return answer
|
| 79 |
|
| 80 |
def process_message(recieved_msg):
|
app.py
CHANGED
|
@@ -86,7 +86,6 @@ def get_health():
|
|
| 86 |
|
| 87 |
@app.post("/Message/Send/")
|
| 88 |
def call(request: RequestModel):
|
| 89 |
-
print(f"Received request: {str(request)}")
|
| 90 |
redis_send(request.user_id,request.msg_id,{"status": "pending"})
|
| 91 |
return send_message(json.dumps(request.model_dump()))
|
| 92 |
|
|
@@ -96,7 +95,6 @@ def call(request: RequestAnswer):
|
|
| 96 |
## MUST BE LIGHTWEIGHT, JUST CHECK IF ANSWER IS READY IN REDIS, IF YES RETURN IT, ELSE RETURN PENDING
|
| 97 |
try:
|
| 98 |
answer = redis_conn.get(f'ANSWER_FOR_USER_ID{request.user_id}_OF_{request.msg_id}')
|
| 99 |
-
print(f"Fetched answer from Redis for user_id {request.user_id} and msg_id {request.msg_id}: {answer}")
|
| 100 |
if answer is None:
|
| 101 |
return {"status": "error"}
|
| 102 |
elif "status" in answer and json.loads(answer)["status"] == "pending":
|
|
|
|
| 86 |
|
| 87 |
@app.post("/Message/Send/")
|
| 88 |
def call(request: RequestModel):
|
|
|
|
| 89 |
redis_send(request.user_id,request.msg_id,{"status": "pending"})
|
| 90 |
return send_message(json.dumps(request.model_dump()))
|
| 91 |
|
|
|
|
| 95 |
## MUST BE LIGHTWEIGHT, JUST CHECK IF ANSWER IS READY IN REDIS, IF YES RETURN IT, ELSE RETURN PENDING
|
| 96 |
try:
|
| 97 |
answer = redis_conn.get(f'ANSWER_FOR_USER_ID{request.user_id}_OF_{request.msg_id}')
|
|
|
|
| 98 |
if answer is None:
|
| 99 |
return {"status": "error"}
|
| 100 |
elif "status" in answer and json.loads(answer)["status"] == "pending":
|