vrr/eigent
2
0
Fork 0
mirror of https://github.com/eigent-ai/eigent.git synced 2026-05-16 19:50:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

remove redundent dom log

Browse source
This commit is contained in:
puzhen 2025-10-17 20:51:27 +01:00
parent c09e62c636
commit d70c002f4c
2 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

5
backend/app/utils/listen/toolkit_listen.py
View file

@ -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):

9
backend/app/utils/toolkit/hybrid_browser_toolkit.py
View file

@ -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"