vodorod/Dorod-Sky
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix skyvern client bug (#1802)

Browse Source
This commit is contained in:
LawyZheng
2025-02-21 02:18:02 +08:00
committed by GitHub
parent ceb1012046
commit 902c0ad4ce
3 changed files with 227 additions and 844 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1060
poetry.lock generated
View File

File diff suppressed because it is too large Load Diff

3
pyproject.toml
View File

@@ -54,8 +54,6 @@ pyotp = "^2.9.0"
asyncpg = "^0.30.0" asyncpg = "^0.30.0"
json-repair = "^0.34.0" json-repair = "^0.34.0"
pypdf = "^5.1.0" pypdf = "^5.1.0"
langchain = "^0.3.18"
llama-index = "^0.12.16"
[tool.poetry.group.dev.dependencies] [tool.poetry.group.dev.dependencies]
isort = "^5.13.2" isort = "^5.13.2"
@@ -80,6 +78,7 @@ fpdf = "^1.7.2"
pypdf = "^5.0.1" pypdf = "^5.0.1"
twine = "^6.1.0" twine = "^6.1.0"
build = "^1.2.2.post1" build = "^1.2.2.post1"
pandas = "^2.2.3"
[build-system] [build-system]

8
skyvern/agent/local.py
View File

@@ -145,8 +145,8 @@ class Agent:
) -> TaskResponse: ) -> TaskResponse:
created_task = await self.create_task(task_request) created_task = await self.create_task(task_request)
while True: async with asyncio.timeout(timeout_seconds):
async with asyncio.timeout(timeout_seconds): while True:
task_response = await self.get_task(created_task.task_id) task_response = await self.get_task(created_task.task_id)
assert task_response is not None assert task_response is not None
if task_response.status.is_final(): if task_response.status.is_final():
@@ -182,8 +182,8 @@ class Agent:
) -> ObserverTask: ) -> ObserverTask:
observer_task = await self.observer_task_v_2(task_request) observer_task = await self.observer_task_v_2(task_request)
while True: async with asyncio.timeout(timeout_seconds):
async with asyncio.timeout(timeout_seconds): while True:
refreshed_observer_task = await self.get_observer_task_v_2(observer_task.observer_cruise_id) refreshed_observer_task = await self.get_observer_task_v_2(observer_task.observer_cruise_id)
assert refreshed_observer_task is not None assert refreshed_observer_task is not None
if refreshed_observer_task.status.is_final(): if refreshed_observer_task.status.is_final():