From c575ad8bc7b429a77fb2a6335a37e6e572eee85c Mon Sep 17 00:00:00 2001 From: Shuchang Zheng Date: Tue, 27 May 2025 03:21:50 -0700 Subject: [PATCH] fix webhook successful status code range (#2486) --- skyvern/forge/agent.py | 2 +- skyvern/forge/sdk/workflow/service.py | 2 +- skyvern/services/task_v2_service.py | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/skyvern/forge/agent.py b/skyvern/forge/agent.py index 0472d4e4..2b2e68e2 100644 --- a/skyvern/forge/agent.py +++ b/skyvern/forge/agent.py @@ -2139,7 +2139,7 @@ class ForgeAgent: resp = await client.post( task.webhook_callback_url, data=payload, headers=headers, timeout=httpx.Timeout(30.0) ) - if resp.status_code == 200: + if resp.status_code >= 200 and resp.status_code < 300: LOG.info( "Webhook sent successfully", task_id=task.task_id, diff --git a/skyvern/forge/sdk/workflow/service.py b/skyvern/forge/sdk/workflow/service.py index a08ce706..84386b5a 100644 --- a/skyvern/forge/sdk/workflow/service.py +++ b/skyvern/forge/sdk/workflow/service.py @@ -1268,7 +1268,7 @@ class WorkflowService: resp = await client.post( url=workflow_run.webhook_callback_url, data=payload, headers=headers, timeout=httpx.Timeout(30.0) ) - if resp.status_code == 200: + if resp.status_code >= 200 and resp.status_code < 300: LOG.info( "Webhook sent successfully", workflow_id=workflow_id, diff --git a/skyvern/services/task_v2_service.py b/skyvern/services/task_v2_service.py index 85960b8c..06484f18 100644 --- a/skyvern/services/task_v2_service.py +++ b/skyvern/services/task_v2_service.py @@ -1678,7 +1678,7 @@ async def send_task_v2_webhook(task_v2: TaskV2) -> None: resp = await httpx.AsyncClient().post( task_v2.webhook_callback_url, data=payload, headers=headers, timeout=httpx.Timeout(30.0) ) - if resp.status_code == 200: + if resp.status_code >= 200 and resp.status_code < 300: LOG.info( "Task v2 webhook sent successfully", task_v2_id=task_v2.observer_cruise_id,