vodorod/Dorod-Sky
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

remove noisy websocket / nvc logs (#4292)

Browse Source
This commit is contained in:
Shuchang Zheng
2025-12-13 10:18:05 -08:00
committed by GitHub
parent 6fffa5cc02
commit 11156fed41
5 changed files with 1 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
skyvern/forge/sdk/routes/streaming/channels/message.py
View File

@@ -260,7 +260,7 @@ class MessageChannel:
) )
if datums: 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 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. 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 = await verify_browser_session(
browser_session_id=browser_session_id, browser_session_id=browser_session_id,
organization_id=organization_id, organization_id=organization_id,
) )
if not browser_session: 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 return None
message_channel = MessageChannel( message_channel = MessageChannel(
@@ -566,8 +559,6 @@ async def get_message_channel_for_browser_session(
websocket=websocket, websocket=websocket,
) )
LOG.info("Got message channel for browser session.", message_channel=message_channel)
loops = [ loops = [
asyncio.create_task(loop_verify_browser_session(message_channel)), asyncio.create_task(loop_verify_browser_session(message_channel)),
asyncio.create_task(loop_stream_messages(message_channel)), asyncio.create_task(loop_stream_messages(message_channel)),
@@ -602,11 +593,6 @@ async def get_message_channel_for_workflow_run(
return None return None
if not browser_session: 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 return None
message_channel = MessageChannel( message_channel = MessageChannel(

11
skyvern/forge/sdk/routes/streaming/channels/vnc.py
View File

@@ -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. 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 = await verify_browser_session(
browser_session_id=browser_session_id, browser_session_id=browser_session_id,
organization_id=organization_id, organization_id=organization_id,
) )
if not browser_session: if not browser_session:
LOG.info(
"No initial browser session found.", browser_session_id=browser_session_id, organization_id=organization_id
)
return None return None
x_api_key = await get_x_api_key(organization_id) x_api_key = await get_x_api_key(organization_id)
@@ -516,7 +511,6 @@ async def get_vnc_channel_for_task(
return None return None
if not browser_session: if not browser_session:
LOG.info("No initial browser session found for task.", task_id=task_id, organization_id=organization_id)
return None return None
x_api_key = await get_x_api_key(organization_id) x_api_key = await get_x_api_key(organization_id)
@@ -562,11 +556,6 @@ async def get_vnc_channel_for_workflow_run(
return None return None
if not browser_session: 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 return None
x_api_key = await get_x_api_key(organization_id) x_api_key = await get_x_api_key(organization_id)

6
skyvern/forge/sdk/routes/streaming/messages.py
View File

@@ -60,12 +60,6 @@ async def messages(
client_id: str | None = None, client_id: str | None = None,
token: str | None = None, token: str | None = 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) organization_id = await auth(apikey=apikey, token=token, websocket=websocket)
if not organization_id: if not organization_id:

6
skyvern/forge/sdk/routes/streaming/verify.py
View File

@@ -68,12 +68,6 @@ async def verify_browser_session(
return None return None
if is_final_status(browser_session.status): 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 return None
started_at = browser_session.started_at started_at = browser_session.started_at

6
skyvern/forge/sdk/routes/streaming/vnc.py
View File

@@ -113,12 +113,6 @@ async def stream(
return return
vnc_channel, loops = result vnc_channel, loops = result
LOG.info(
"Starting vnc for browser session.",
browser_session_id=browser_session_id,
organization_id=organization_id,
)
elif task_id: elif task_id:
result = await get_vnc_channel_for_task( result = await get_vnc_channel_for_task(
client_id=client_id, client_id=client_id,