christian/matrix-ai-agent
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: increase httpx timeout to 60s for Skyvern API calls

Browse Source 
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
Christian Gick
2026-03-19 10:07:20 +02:00
parent 3aac724627
commit 1d7730fbf7
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
cron/browser_executor.py
View File

@@ -32,7 +32,7 @@ async def _create_task(url: str, goal: str, extraction_goal: str = "",
if totp_identifier: if totp_identifier:
payload["totp_identifier"] = totp_identifier payload["totp_identifier"] = totp_identifier
async with httpx.AsyncClient(timeout=30.0) as client: async with httpx.AsyncClient(timeout=60.0) as client:
resp = await client.post( resp = await client.post(
f"{SKYVERN_BASE_URL}/api/v1/tasks", f"{SKYVERN_BASE_URL}/api/v1/tasks",
headers={ headers={
@@ -49,7 +49,7 @@ async def _create_task(url: str, goal: str, extraction_goal: str = "",
async def _poll_task(run_id: str) -> dict: async def _poll_task(run_id: str) -> dict:
"""Poll Skyvern until task completes or times out.""" """Poll Skyvern until task completes or times out."""
elapsed = 0 elapsed = 0
async with httpx.AsyncClient(timeout=15.0) as client: async with httpx.AsyncClient(timeout=60.0) as client:
while elapsed < MAX_POLL_TIME: while elapsed < MAX_POLL_TIME:
resp = await client.get( resp = await client.get(
f"{SKYVERN_BASE_URL}/api/v1/tasks/{run_id}", f"{SKYVERN_BASE_URL}/api/v1/tasks/{run_id}",

4
pipelines/steps/skyvern.py
View File

@@ -61,7 +61,7 @@ async def execute_skyvern(config: dict, send_text=None, target_room: str = "", *
"x-api-key": SKYVERN_API_KEY, "x-api-key": SKYVERN_API_KEY,
} }
async with httpx.AsyncClient(timeout=30.0) as client: async with httpx.AsyncClient(timeout=60.0) as client:
resp = await client.post( resp = await client.post(
f"{SKYVERN_BASE_URL}/api/v1/tasks", f"{SKYVERN_BASE_URL}/api/v1/tasks",
headers=headers, headers=headers,
@@ -77,7 +77,7 @@ async def execute_skyvern(config: dict, send_text=None, target_room: str = "", *
# Poll for completion # Poll for completion
elapsed = 0 elapsed = 0
async with httpx.AsyncClient(timeout=15.0) as client: async with httpx.AsyncClient(timeout=60.0) as client:
while elapsed < max_poll: while elapsed < max_poll:
resp = await client.get( resp = await client.get(
f"{SKYVERN_BASE_URL}/api/v1/tasks/{run_id}", f"{SKYVERN_BASE_URL}/api/v1/tasks/{run_id}",