Feature/entry node logs deprecation

validator/entry_node/src/endpoints/image.py

@@ -81,14 +81,14 @@ async def make_non_stream_organic_query(
     except asyncio.TimeoutError:
         logger.error(f"No confirmation received for job {job_id} within timeout period. Task: {task}")
         COUNTER_IMAGE_ERROR.add(1, {"task": task, "kind": "redis_acknowledgement_timeout", "status_code": 500})
-        raise HTTPException(status_code=500, detail=f"Unable to process task: {task} ; redis_acknowledgement_timeout, please try again later.")
+        raise HTTPException(status_code=500, detail=f"Unable to process task: {task}, please try again later.")
 
     try:
         return await asyncio.wait_for(_collect_single_result(pubsub, job_id), timeout=timeout)
     except asyncio.TimeoutError:
         logger.error(f"Timed out waiting for the first chunk of results for job {job_id}. Task: {task}")
         COUNTER_IMAGE_ERROR.add(1, {"task": task, "kind": "_collect_single_result_failed", "status_code": 500})
-        raise HTTPException(status_code=500, detail=f"Unable to process task: {task} ; _collect_single_result_failed, please try again later.")
+        raise HTTPException(status_code=500, detail=f"Unable to process task: {task}, please try again later.")
 
 
 

validator/entry_node/src/endpoints/text.py

@@ -108,7 +108,7 @@ async def make_stream_organic_query(
             f"Query node down? No confirmation received for job {job_id} within timeout period. Task: {task}, model: {payload['model']}"
         )
         COUNTER_TEXT_GENERATION_ERROR.add(1, {"task": task, "kind": "redis_acknowledgement_timeout", "status_code": 500})
-        raise HTTPException(status_code=500, detail="Unable to process request ; redis_acknowledgement_timeout")
+        raise HTTPException(status_code=500, detail="Unable to process request")
 
     await pubsub.subscribe(f"{rcst.JOB_RESULTS}:{job_id}")
     logger.info("Here waiting for a message!")
@@ -120,11 +120,11 @@ async def make_stream_organic_query(
             f"Query node down? Timed out waiting for the first chunk of results for job {job_id}. Task: {task}, model: {payload['model']}"
         )
         COUNTER_TEXT_GENERATION_ERROR.add(1, {"task": task, "kind": "first_chunk_timeout", "status_code": 500})
-        raise HTTPException(status_code=500, detail="Unable to process request ; first_chunk_timeout")
+        raise HTTPException(status_code=500, detail="Unable to process request")
 
     if first_chunk is None:
         COUNTER_TEXT_GENERATION_ERROR.add(1, {"task": task, "kind": "first_chunk_missing", "status_code": 500})
-        raise HTTPException(status_code=500, detail="Unable to process request ; first_chunk_missing")
+        raise HTTPException(status_code=500, detail="Unable to process request")
     return _stream_results(pubsub, job_id, task, first_chunk, start_time)