diff --git a/cron/browser_executor.py b/cron/browser_executor.py index e00d597..e1a4d47 100644 --- a/cron/browser_executor.py +++ b/cron/browser_executor.py @@ -32,7 +32,7 @@ async def _create_task(url: str, goal: str, extraction_goal: str = "", if 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( f"{SKYVERN_BASE_URL}/api/v1/tasks", headers={ @@ -49,7 +49,7 @@ async def _create_task(url: str, goal: str, extraction_goal: str = "", async def _poll_task(run_id: str) -> dict: """Poll Skyvern until task completes or times out.""" 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: resp = await client.get( f"{SKYVERN_BASE_URL}/api/v1/tasks/{run_id}", diff --git a/pipelines/steps/skyvern.py b/pipelines/steps/skyvern.py index f7f76f4..feb743d 100644 --- a/pipelines/steps/skyvern.py +++ b/pipelines/steps/skyvern.py @@ -61,7 +61,7 @@ async def execute_skyvern(config: dict, send_text=None, target_room: str = "", * "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( f"{SKYVERN_BASE_URL}/api/v1/tasks", headers=headers, @@ -77,7 +77,7 @@ async def execute_skyvern(config: dict, send_text=None, target_room: str = "", * # Poll for completion elapsed = 0 - async with httpx.AsyncClient(timeout=15.0) as client: + async with httpx.AsyncClient(timeout=60.0) as client: while elapsed < max_poll: resp = await client.get( f"{SKYVERN_BASE_URL}/api/v1/tasks/{run_id}",