vikarti.anatra/Skyvern
1
0
Fork 0
mirror of https://github.com/Skyvern-AI/skyvern.git synced 2025-09-14 17:29:40 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

fix webhook successful status code range (#2486)

Browse source
This commit is contained in:
Shuchang Zheng 2025-05-27 03:21:50 -07:00 • committed by GitHub
parent de18a60ac2
commit c575ad8bc7
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
skyvern/forge/agent.py
View file

@ -2139,7 +2139,7 @@ class ForgeAgent:
resp = await client.post( resp = await client.post(
task.webhook_callback_url, data=payload, headers=headers, timeout=httpx.Timeout(30.0) 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( LOG.info(
"Webhook sent successfully", "Webhook sent successfully",
task_id=task.task_id, task_id=task.task_id,

2
skyvern/forge/sdk/workflow/service.py
View file

@ -1268,7 +1268,7 @@ class WorkflowService:
resp = await client.post( resp = await client.post(
url=workflow_run.webhook_callback_url, data=payload, headers=headers, timeout=httpx.Timeout(30.0) 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( LOG.info(
"Webhook sent successfully", "Webhook sent successfully",
workflow_id=workflow_id, workflow_id=workflow_id,

2
skyvern/services/task_v2_service.py
View file

@ -1678,7 +1678,7 @@ async def send_task_v2_webhook(task_v2: TaskV2) -> None:
resp = await httpx.AsyncClient().post( resp = await httpx.AsyncClient().post(
task_v2.webhook_callback_url, data=payload, headers=headers, timeout=httpx.Timeout(30.0) 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( LOG.info(
"Task v2 webhook sent successfully", "Task v2 webhook sent successfully",
task_v2_id=task_v2.observer_cruise_id, task_v2_id=task_v2.observer_cruise_id,