Skip to content

Commit 8d1d3b8

Browse files
committed
fix: Log requests/responses at DEBUG level
Signed-off-by: Phoevos Kalemkeris <[email protected]>
1 parent 45e9c22 commit 8d1d3b8

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

cogstack_model_gateway/gateway/routers/models.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -275,7 +275,8 @@ async def execute_task(
275275
}
276276
priority = calculate_task_priority(task, config)
277277

278-
log.info(f"Executing task: {task}")
278+
log.info(f"Executing task '{task['uuid']}': {task['method']} {task['url']}")
279+
log.debug(f"Task details: {task}")
279280
qm: QueueManager = config.queue_manager
280281
qm.publish(task, priority)
281282

cogstack_model_gateway/scheduler/scheduler.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ def route_task(self, task: dict) -> tuple[requests.Response, str]:
4646
request = self._prepare_request(task)
4747

4848
try:
49-
log.info(f"Request: {request}")
49+
log.debug(f"Request: {request}")
5050
response = requests.request(
5151
method=request["method"],
5252
url=request["url"],
@@ -61,7 +61,7 @@ def route_task(self, task: dict) -> tuple[requests.Response, str]:
6161
return None, err_msg
6262

6363
try:
64-
log.info(f"Response: {response.text}")
64+
log.debug(f"Response: {response.text}")
6565
response.raise_for_status()
6666
log.info(f"Task '{task['uuid']}' forwarded successfully to {task['url']}")
6767
return response, None

0 commit comments

Comments
 (0)