fix unbounded variable bug in observer service (#1789)
This commit is contained in:
@@ -165,7 +165,7 @@ async def initialize_observer_task(
|
|||||||
# fail the workflow run
|
# fail the workflow run
|
||||||
await mark_observer_task_as_failed(
|
await mark_observer_task_as_failed(
|
||||||
observer_cruise_id=observer_task.observer_cruise_id,
|
observer_cruise_id=observer_task.observer_cruise_id,
|
||||||
workflow_run_id=workflow_run.workflow_run_id,
|
workflow_run_id=observer_task.workflow_run_id,
|
||||||
failure_reason="Skyvern failed to setup the workflow run",
|
failure_reason="Skyvern failed to setup the workflow run",
|
||||||
organization_id=organization.organization_id,
|
organization_id=organization.organization_id,
|
||||||
)
|
)
|
||||||
@@ -186,7 +186,7 @@ async def initialize_observer_task(
|
|||||||
|
|
||||||
# update oserver cruise
|
# update oserver cruise
|
||||||
try:
|
try:
|
||||||
observer_task = await app.DATABASE.update_observer_cruise(
|
observer_task = await app.database.update_observer_cruise(
|
||||||
observer_cruise_id=observer_task.observer_cruise_id,
|
observer_cruise_id=observer_task.observer_cruise_id,
|
||||||
workflow_run_id=workflow_run.workflow_run_id,
|
workflow_run_id=workflow_run.workflow_run_id,
|
||||||
workflow_id=new_workflow.workflow_id,
|
workflow_id=new_workflow.workflow_id,
|
||||||
|
|||||||
Reference in New Issue
Block a user