From 11156fed41e20bb5ea5c16fd50360987238c9217 Mon Sep 17 00:00:00 2001 From: Shuchang Zheng Date: Sat, 13 Dec 2025 10:18:05 -0800 Subject: [PATCH] remove noisy websocket / nvc logs (#4292) --- .../sdk/routes/streaming/channels/message.py | 16 +--------------- .../forge/sdk/routes/streaming/channels/vnc.py | 11 ----------- skyvern/forge/sdk/routes/streaming/messages.py | 6 ------ skyvern/forge/sdk/routes/streaming/verify.py | 6 ------ skyvern/forge/sdk/routes/streaming/vnc.py | 6 ------ 5 files changed, 1 insertion(+), 44 deletions(-) diff --git a/skyvern/forge/sdk/routes/streaming/channels/message.py b/skyvern/forge/sdk/routes/streaming/channels/message.py index ab5e72ba..8fa73314 100644 --- a/skyvern/forge/sdk/routes/streaming/channels/message.py +++ b/skyvern/forge/sdk/routes/streaming/channels/message.py @@ -260,7 +260,7 @@ class MessageChannel: ) if datums: - LOG.info(f"{self.class_name} Drained {len(datums)} messages from message channel.", **self.identity) + LOG.debug(f"{self.class_name} Drained {len(datums)} messages from message channel.", **self.identity) return datums @@ -544,19 +544,12 @@ async def get_message_channel_for_browser_session( Return a message channel for a browser session, with a list of loops to run concurrently. """ - LOG.info("Getting message channel for browser session.", browser_session_id=browser_session_id) - browser_session = await verify_browser_session( browser_session_id=browser_session_id, organization_id=organization_id, ) if not browser_session: - LOG.info( - "Message channel: no initial browser session found.", - browser_session_id=browser_session_id, - organization_id=organization_id, - ) return None message_channel = MessageChannel( @@ -566,8 +559,6 @@ async def get_message_channel_for_browser_session( websocket=websocket, ) - LOG.info("Got message channel for browser session.", message_channel=message_channel) - loops = [ asyncio.create_task(loop_verify_browser_session(message_channel)), asyncio.create_task(loop_stream_messages(message_channel)), @@ -602,11 +593,6 @@ async def get_message_channel_for_workflow_run( return None if not browser_session: - LOG.info( - "Message channel: no initial browser session found for workflow run.", - workflow_run_id=workflow_run_id, - organization_id=organization_id, - ) return None message_channel = MessageChannel( diff --git a/skyvern/forge/sdk/routes/streaming/channels/vnc.py b/skyvern/forge/sdk/routes/streaming/channels/vnc.py index a58bc662..36f3d2dd 100644 --- a/skyvern/forge/sdk/routes/streaming/channels/vnc.py +++ b/skyvern/forge/sdk/routes/streaming/channels/vnc.py @@ -460,17 +460,12 @@ async def get_vnc_channel_for_browser_session( Return a vnc channel for a browser session, with a list of loops to run concurrently. """ - LOG.info("Getting vnc context for browser session.", browser_session_id=browser_session_id) - browser_session = await verify_browser_session( browser_session_id=browser_session_id, organization_id=organization_id, ) if not browser_session: - LOG.info( - "No initial browser session found.", browser_session_id=browser_session_id, organization_id=organization_id - ) return None x_api_key = await get_x_api_key(organization_id) @@ -516,7 +511,6 @@ async def get_vnc_channel_for_task( return None if not browser_session: - LOG.info("No initial browser session found for task.", task_id=task_id, organization_id=organization_id) return None x_api_key = await get_x_api_key(organization_id) @@ -562,11 +556,6 @@ async def get_vnc_channel_for_workflow_run( return None if not browser_session: - LOG.info( - "No initial browser session found for workflow run.", - workflow_run_id=workflow_run_id, - organization_id=organization_id, - ) return None x_api_key = await get_x_api_key(organization_id) diff --git a/skyvern/forge/sdk/routes/streaming/messages.py b/skyvern/forge/sdk/routes/streaming/messages.py index 74b5295d..0059fb82 100644 --- a/skyvern/forge/sdk/routes/streaming/messages.py +++ b/skyvern/forge/sdk/routes/streaming/messages.py @@ -60,12 +60,6 @@ async def messages( client_id: str | None = None, token: str | None = None, ) -> None: - LOG.info( - "Starting message stream.", - browser_session_id=browser_session_id, - workflow_run_id=workflow_run_id, - ) - organization_id = await auth(apikey=apikey, token=token, websocket=websocket) if not organization_id: diff --git a/skyvern/forge/sdk/routes/streaming/verify.py b/skyvern/forge/sdk/routes/streaming/verify.py index d5f63790..54bbf27b 100644 --- a/skyvern/forge/sdk/routes/streaming/verify.py +++ b/skyvern/forge/sdk/routes/streaming/verify.py @@ -68,12 +68,6 @@ async def verify_browser_session( return None if is_final_status(browser_session.status): - LOG.info( - "Browser session is invalid, as it is in a final state.", - browser_session_status=browser_session.status, - browser_session_id=browser_session_id, - organization_id=organization_id, - ) return None started_at = browser_session.started_at diff --git a/skyvern/forge/sdk/routes/streaming/vnc.py b/skyvern/forge/sdk/routes/streaming/vnc.py index 6bf076d7..97124b30 100644 --- a/skyvern/forge/sdk/routes/streaming/vnc.py +++ b/skyvern/forge/sdk/routes/streaming/vnc.py @@ -113,12 +113,6 @@ async def stream( return vnc_channel, loops = result - - LOG.info( - "Starting vnc for browser session.", - browser_session_id=browser_session_id, - organization_id=organization_id, - ) elif task_id: result = await get_vnc_channel_for_task( client_id=client_id,