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

fail workflow run when running into cruise initialization errors (#1458)

Browse Source
This commit is contained in:
Shuchang Zheng
2024-12-31 14:07:03 -08:00
committed by GitHub
parent 8c08edfb78
commit 7b058c224f
2 changed files with 60 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
skyvern/forge/sdk/routes/agent_protocol.py
View File

@@ -1084,11 +1084,17 @@ async def observer_cruise(
if x_max_iterations_override: if x_max_iterations_override:
LOG.info("Overriding max iterations for observer", max_iterations_override=x_max_iterations_override) LOG.info("Overriding max iterations for observer", max_iterations_override=x_max_iterations_override)
observer_cruise = await observer_service.initialize_observer_cruise( try:
organization=organization, observer_cruise = await observer_service.initialize_observer_cruise(
user_prompt=data.user_prompt, organization=organization,
user_url=str(data.url) if data.url else None, user_prompt=data.user_prompt,
) user_url=str(data.url) if data.url else None,
)
except LLMProviderError:
LOG.error("LLM failure to initialize observer cruise", exc_info=True)
raise HTTPException(
status_code=500, detail="Skyvern LLM failure to initialize observer cruise. Please try again later."
)
analytics.capture("skyvern-oss-agent-observer-cruise", data={"url": observer_cruise.url}) analytics.capture("skyvern-oss-agent-observer-cruise", data={"url": observer_cruise.url})
await AsyncExecutorFactory.get_executor().execute_cruise( await AsyncExecutorFactory.get_executor().execute_cruise(
request=request, request=request,

75
skyvern/forge/sdk/services/observer_service.py
View File

@@ -109,34 +109,57 @@ async def initialize_observer_cruise(
# create workflow and workflow run # create workflow and workflow run
max_steps_override = 10 max_steps_override = 10
new_workflow = await app.WORKFLOW_SERVICE.create_empty_workflow(organization, metadata.workflow_title) try:
workflow_run = await app.WORKFLOW_SERVICE.setup_workflow_run( new_workflow = await app.WORKFLOW_SERVICE.create_empty_workflow(organization, metadata.workflow_title)
request_id=None, workflow_run = await app.WORKFLOW_SERVICE.setup_workflow_run(
workflow_request=WorkflowRequestBody(), request_id=None,
workflow_permanent_id=new_workflow.workflow_permanent_id, workflow_request=WorkflowRequestBody(),
organization_id=organization.organization_id, workflow_permanent_id=new_workflow.workflow_permanent_id,
version=None, organization_id=organization.organization_id,
max_steps_override=max_steps_override, version=None,
) max_steps_override=max_steps_override,
await app.DATABASE.update_observer_thought( )
observer_thought_id=observer_thought.observer_thought_id, except Exception:
organization_id=organization.organization_id, LOG.error("Failed to setup cruise workflow run", exc_info=True)
workflow_run_id=workflow_run.workflow_run_id, # fail the workflow run
workflow_id=new_workflow.workflow_id, await app.WORKFLOW_SERVICE.mark_workflow_run_as_failed(
workflow_permanent_id=new_workflow.workflow_permanent_id, workflow_run_id=workflow_run.workflow_run_id,
thought=metadata_response.get("thoughts", ""), failure_reason="Skyvern failed to setup the workflow run",
output=metadata.model_dump(), )
) raise
try:
await app.DATABASE.update_observer_thought(
observer_thought_id=observer_thought.observer_thought_id,
organization_id=organization.organization_id,
workflow_run_id=workflow_run.workflow_run_id,
workflow_id=new_workflow.workflow_id,
workflow_permanent_id=new_workflow.workflow_permanent_id,
thought=metadata_response.get("thoughts", ""),
output=metadata.model_dump(),
)
except Exception:
LOG.warning("Failed to update observer thought", exc_info=True)
# update oserver cruise # update oserver cruise
observer_cruise = await app.DATABASE.update_observer_cruise( try:
observer_cruise_id=observer_cruise.observer_cruise_id, observer_cruise = await app.DATABASE.update_observer_cruise(
workflow_run_id=workflow_run.workflow_run_id, observer_cruise_id=observer_cruise.observer_cruise_id,
workflow_id=new_workflow.workflow_id, workflow_run_id=workflow_run.workflow_run_id,
workflow_permanent_id=new_workflow.workflow_permanent_id, workflow_id=new_workflow.workflow_id,
url=url, workflow_permanent_id=new_workflow.workflow_permanent_id,
organization_id=organization.organization_id, url=url,
) organization_id=organization.organization_id,
)
except Exception:
LOG.warning("Failed to update observer cruise", exc_info=True)
# fail the workflow run
await app.WORKFLOW_SERVICE.mark_workflow_run_as_failed(
workflow_run_id=workflow_run.workflow_run_id,
failure_reason="Skyvern failed to update the observer cruise after initializing the workflow run",
)
raise
return observer_cruise return observer_cruise