diff --git a/backend/app/utils/listen/toolkit_listen.py b/backend/app/utils/listen/toolkit_listen.py index 63de14117..1d7fd85a6 100644 --- a/backend/app/utils/listen/toolkit_listen.py +++ b/backend/app/utils/listen/toolkit_listen.py @@ -36,7 +36,6 @@ def _safe_put_queue(task_lock, data): asyncio.set_event_loop(new_loop) try: new_loop.run_until_complete(task_lock.put_queue(data)) - logger.debug(f"[listen_toolkit] Successfully sent data to queue using new event loop") finally: new_loop.close() except Exception as e: @@ -96,7 +95,6 @@ def listen_toolkit( "message": args_str, }, ) - logger.debug(f"[listen_toolkit] Sending activate data: {activate_data.model_dump()}") await task_lock.put_queue(activate_data) error = None res = None @@ -134,7 +132,6 @@ def listen_toolkit( "message": res_msg, }, ) - logger.debug(f"[listen_toolkit] Sending deactivate data: {deactivate_data.model_dump()}") await task_lock.put_queue(deactivate_data) if error is not None: raise error @@ -181,12 +178,10 @@ def listen_toolkit( "message": args_str, }, ) - logger.debug(f"[listen_toolkit sync] Sending activate data: {activate_data.model_dump()}") _safe_put_queue(task_lock, activate_data) error = None res = None try: - logger.debug(f"Executing toolkit method: {toolkit_name}.{method_name} for agent '{toolkit.agent_name}'") res = func(*args, **kwargs) # Safety check: if the result is a coroutine, we need to await it if asyncio.iscoroutine(res): diff --git a/backend/app/utils/toolkit/hybrid_browser_toolkit.py b/backend/app/utils/toolkit/hybrid_browser_toolkit.py index 94a288fe0..ed1e6d486 100644 --- a/backend/app/utils/toolkit/hybrid_browser_toolkit.py +++ b/backend/app/utils/toolkit/hybrid_browser_toolkit.py @@ -45,8 +45,13 @@ class WebSocketBrowserWrapper(BaseWebSocketBrowserWrapper): future.set_result(response) logger.debug(f"Processed response for message {message_id}") else: - # Log unexpected messages - logger.warning(f"Received unexpected message: {response}") + message_summary = { + "id": response.get("id"), + "success": response.get("success"), + "has_result": "result" in response, + "result_type": type(response.get("result")).__name__ if "result" in response else None + } + logger.debug(f"Received unexpected message: {message_summary}") except asyncio.CancelledError: disconnect_reason = "Receive loop cancelled"