Update lint rules and fix new warnings

[creatorrr]

Summary

• include openapi_model.py in linting
• enable ARG and PTH rule groups
• fix new lint warnings across the codebase

Testing

• ruff check --no-fix .

[qodo-merge-for-open-source]

CI Feedback 🧐

(Feedback updated until commit 9f6efd0)

A test triggered by this PR failed. Here is an AI-generated analysis of the failure:

Action: Test

Failed stage: [❌]

Failed test name: test_execution_queries

Failure summary: The action failed because three tests in test_execution_queries.py failed: 1. test_execution_queries:85 query: list executions 2. test_execution_queries:199 query: count executions 3. test_execution_queries:217 query: create execution transition All three failures have the same root cause: the create_execution_transition() function is being called with a developer_id parameter, but this parameter is not accepted by the function. The error message is: TypeError: create_execution_transition() got an unexpected keyword argument 'developer_id'. This suggests that either: The function signature for create_execution_transition() was recently changed to remove the developer_id parameter, but the tests weren't updated Or the tests are expecting a parameter that was never implemented in the function

Relevant error logs: 1: ##[group]Operating System 2: Ubuntu ... 965: prune-cache: true 966: ignore-nothing-to-cache: false 967: ##[endgroup] 968: Downloading uv from "https://github.com/astral-sh/uv/releases/download/0.7.6/uv-x86_64-unknown-linux-gnu.tar.gz" ... 969: [command]/usr/bin/tar xz --warning=no-unknown-keyword --overwrite -C /home/runner/work/_temp/1dd81f4e-2bc3-4c7a-94fe-6cf154b220a8 -f /home/runner/work/_temp/73a44454-0ff0-4d33-94ee-b004ce0d0165 970: Added /opt/hostedtoolcache/uv/0.7.6/x86_64 to the path 971: Added /home/runner/.local/bin to the path 972: Set UV_CACHE_DIR to /home/runner/work/_temp/setup-uv-cache 973: Successfully installed uv version 0.7.6 974: Searching files using cache dependency glob: **/uv.lock 975: /home/runner/work/julep/julep/agents-api/uv.lock 976: /home/runner/work/julep/julep/cli/uv.lock 977: /home/runner/work/julep/julep/integrations-service/uv.lock 978: Found 3 files to hash. 979: Trying to restore uv cache from GitHub Actions cache with key: setup-uv-1-x86_64-unknown-linux-gnu-0.7.6-d92603d25acef1c08e643c37cc2475e5e190deb9690356b084828d60043a591f 980: ##[warning]Failed to restore: Cache service responded with 422 981: No GitHub Actions cache found for key: setup-uv-1-x86_64-unknown-linux-gnu-0.7.6-d92603d25acef1c08e643c37cc2475e5e190deb9690356b084828d60043a591f ... 1488: sql 1489: PASS test_agent_queries:126 query: update agent sql 4% 1490: PASS test_agent_queries:153 query: update agent with project sql 4% 1491: PASS test_agent_queries:177 query: update agent, project does not exist 4% 1492: PASS test_agent_queries:201 query: patch agent sql 5% 1493: PASS test_agent_queries:225 query: patch agent with project sql 5% 1494: PASS test_agent_queries:260 query: patch agent, project does not exist 5% 1495: PASS test_agent_queries:283 query: get agent not exists sql 5% 1496: PASS test_agent_queries:294 query: get agent exists sql 6% 1497: PASS test_agent_queries:315 query: list agents sql 6% 1498: PASS test_agent_queries:326 query: list agents with project filter sql 6% 1499: PASS test_agent_queries:352 query: list agents sql, invalid sort 6% 1500: direction 1501: PASS test_agent_queries:368 query: delete agent sql 6% 1502: INFO:httpx:HTTP Request: POST http://testserver/agents "HTTP/1.1 403 Forbidden" 1503: PASS test_agent_routes:9 route: unauthorized should fail 7% 1504: INFO:httpx:HTTP Request: POST http://testserver/agents "HTTP/1.1 201 Created" ... 1596: PASS test_docs_queries:445 query: delete user doc 20% 1597: PASS test_docs_queries:482 query: delete agent doc 20% 1598: PASS test_docs_queries:519 query: search docs by text 20% 1599: PASS test_docs_queries:556 query: search docs by text with technical 21% 1600: terms and phrases 1601: PASS test_docs_queries:619 query: search docs by embedding 21% 1602: PASS test_docs_queries:647 query: search docs by hybrid 21% 1603: INFO:httpx:HTTP Request: POST http://testserver/users/0682c7bc-cdfc-754e-8000-03decf4642f1/docs "HTTP/1.1 201 Created" 1604: PASS test_docs_routes:15 route: create user doc 21% 1605: INFO:httpx:HTTP Request: POST http://testserver/agents/0682c7bc-d5d4-773a-8000-846d5bca9685/docs "HTTP/1.1 201 Created" 1606: PASS test_docs_routes:32 route: create agent doc 22% 1607: INFO:httpx:HTTP Request: POST http://testserver/agents/0682c7bc-dd85-7804-8000-d0375017badf/docs "HTTP/1.1 201 Created" 1608: INFO:httpx:HTTP Request: POST http://testserver/agents/0682c7bc-dd85-7804-8000-d0375017badf/docs "HTTP/1.1 409 Conflict" 1609: INFO:httpx:HTTP Request: POST http://testserver/users/0682c7bc-e074-76ad-8000-fd2062e49445/docs "HTTP/1.1 201 Created" 1610: PASS test_docs_routes:49 route: create agent doc with duplicate title 22% 1611: should fail 1612: INFO:httpx:HTTP Request: POST http://testserver/agents/0682c7bc-e861-7540-8000-e29e012e27fe/docs "HTTP/1.1 201 Created" ... 1683: PASS test_entry_queries:142 query: list entries sql - session exists 27% 1684: PASS test_entry_queries:180 query: get history sql - session exists 27% 1685: PASS test_entry_queries:219 query: delete entries sql - session exists 28% 1686: PASS test_execution_queries:34 query: create execution 28% 1687: PASS test_execution_queries:59 query: get execution 28% 1688: PASS test_execution_queries:72 query: lookup temporal id 28% 1689: FAIL test_execution_queries:85 query: list executions 29% 1690: PASS test_execution_queries:104 query: list executions, invalid limit 29% 1691: PASS test_execution_queries:136 query: list executions, invalid offset 29% 1692: PASS test_execution_queries:157 query: list executions, invalid sort by 29% 1693: PASS test_execution_queries:178 query: list executions, invalid sort 29% 1694: direction 1695: FAIL test_execution_queries:199 query: count executions 30% 1696: FAIL test_execution_queries:217 query: create execution transition 30% 1697: ──────────────────────────── query: list executions ──────────────────────────── 1698: Failed at tests/test_execution_queries.py 1699: ╭─────────────────── Traceback (most recent call last) ────────────────────╮ 1700: │ /home/runner/work/julep/julep/agents-api/agents_api/queries/utils.py:317 │ 1701: │ in async_wrapper │ 1702: │ │ 1703: │ 314 │ │ @wraps(func) │ 1704: │ 315 │ │ async def async_wrapper(*args: P.args, **kwargs: P.kwargs) │ 1705: │ 316 │ │ │ try: │ 1706: │ ❱ 317 │ │ │ │ result: T = await func(*args, **kwargs) │ 1707: │ 318 │ │ │ except BaseException as error: │ 1708: │ 319 │ │ │ │ _check_error(error) │ 1709: │ 320 │ │ │ │ raise error │ 1710: │ │ ... 1836: │ │ 0x7f984d6dc400> │ │ 1837: │ │ } │ │ 1838: │ │ metric_label = 'create_execution_transition' │ │ 1839: │ │ start_time = 1747745754.9898264 │ │ 1840: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 1841: │ │ 1842: │ /home/runner/work/julep/julep/agents-api/agents_api/queries/utils.py:117 │ 1843: │ in wrapper │ 1844: │ │ 1845: │ 114 │ │ │ connection_pool: asyncpg.Pool | None = None, │ 1846: │ 115 │ │ │ **kwargs: P.kwargs, │ 1847: │ 116 │ │ ) -> list[Record]: │ 1848: │ ❱ 117 │ │ │ query_args = await func(*args, **kwargs) │ 1849: │ 118 │ │ │ batch = prepare_pg_query_args(query_args) │ 1850: │ 119 │ │ │ │ 1851: │ 120 │ │ │ not only_on_error and debug and pprint(batch) │ 1852: │ │ ... 1871: │ │ │ │ │ │ │ 1872: │ │ scope_id=UUID('0682c7bd-acfc-7720-8000-8cd2c0f050… │ │ 1873: │ │ │ │ ), │ │ 1874: │ │ │ │ next=TransitionTarget( │ │ 1875: │ │ │ │ │ workflow='main', │ │ 1876: │ │ │ │ │ step=0, │ │ 1877: │ │ │ │ │ │ │ 1878: │ │ scope_id=UUID('0682c7bd-acfc-7720-8000-8cd2c0f050… │ │ 1879: │ │ │ │ ), │ │ 1880: │ │ │ │ step_label=None, │ │ 1881: │ │ │ │ id=None, │ │ 1882: │ │ │ │ metadata=None, │ │ 1883: │ │ │ │ task_token=None │ │ 1884: │ │ │ ) │ │ 1885: │ │ } │ │ 1886: │ │ only_on_error = False │ │ 1887: │ │ return_index = -1 │ │ ... 1909: │ │ │ │ ), │ │ 1910: │ │ │ │ next=TransitionTarget( │ │ 1911: │ │ │ │ │ workflow='main', │ │ 1912: │ │ │ │ │ step=0, │ │ 1913: │ │ │ │ │ │ │ 1914: │ │ scope_id=UUID('0682c7bd-acfc-7720-8000-8cd2c0f05064') │ │ 1915: │ │ │ │ ), │ │ 1916: │ │ │ │ step_label=None, │ │ 1917: │ │ │ │ id=None, │ │ 1918: │ │ │ │ metadata=None, │ │ 1919: │ │ │ │ task_token=None │ │ 1920: │ │ │ ) │ │ 1921: │ │ } │ │ 1922: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 1923: ╰──────────────────────────────────────────────────────────────────────────╯ 1924: TypeError: create_execution_transition() got an unexpected keyword argument 1925: 'developer_id' ... 2101: │ │ 0x7f984d68c900> │ │ 2102: │ │ │ │ │ │ ), │ │ 2103: │ │ │ │ │ │ │ │ 2104: │ │ '/home/runner/work/julep/julep/agents-api/tests… │ │ 2105: │ │ Fixture( │ │ 2106: │ │ │ │ │ │ │ fn=<function test_execution │ │ 2107: │ │ at 0x7f986ea9f420>, │ │ 2108: │ │ │ │ │ │ │ gen=<async_generator object │ │ 2109: │ │ test_execution at 0x7f983fb97de0>, │ │ 2110: │ │ │ │ │ │ │ resolved_val=Execution( │ │ 2111: │ │ │ │ │ │ │ │ │ │ 2112: │ │ task_id=UUID('0682c7bd-9b48-7f92-8000-80cadc105… │ │ 2113: │ │ │ │ │ │ │ │ status='queued', │ │ 2114: │ │ │ │ │ │ │ │ input={'test': 'test'}, │ │ 2115: │ │ │ │ │ │ │ │ output=None, │ │ 2116: │ │ │ │ │ │ │ │ error=None, │ │ 2117: │ │ │ │ │ │ │ │ transition_count=None, │ │ ... 2260: │ │ 2261: │ ╭───────────────────────────── locals ─────────────────────────────╮ │ 2262: │ │ debug = None │ │ 2263: │ │ loop_factory = None │ │ 2264: │ │ main = <async_generator_asend object at 0x7f986de62900> │ │ 2265: │ │ runner = <asyncio.runners.Runner object at 0x7f984d237ec0> │ │ 2266: │ ╰──────────────────────────────────────────────────────────────────╯ │ 2267: │ │ 2268: │ /home/runner/.local/share/uv/python/cpython-3.12.10-linux-x86_64-gnu/lib │ 2269: │ /python3.12/asyncio/runners.py:118 in run │ 2270: │ │ 2271: │ 115 │ │ │ 2272: │ 116 │ │ self._interrupt_count = 0 │ 2273: │ 117 │ │ try: │ 2274: │ ❱ 118 │ │ │ return self._loop.run_until_complete(task) │ 2275: │ 119 │ │ except exceptions.CancelledError: │ 2276: │ 120 │ │ │ if self._interrupt_count > 0: │ ... 2306: │ ❱ 390 │ await create_execution_transition( │ 2307: │ 391 │ │ developer_id=developer_id, │ 2308: │ 392 │ │ execution_id=execution.id, │ 2309: │ 393 │ │ data=CreateTransitionRequest( │ 2310: │ │ 2311: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 2312: │ │ actual_scope_id = UUID('0682c7bd-acfc-7720-8000-8cd2c0f05064') │ │ 2313: │ │ developer_id = UUID('00000000-0000-0000-0000-000000000000') │ │ 2314: │ │ dsn = '***localhost:32769/test?sslmod… │ │ 2315: │ │ execution = Execution( │ │ 2316: │ │ │ │ │ 2317: │ │ task_id=UUID('0682c7bd-acc5-7076-8000-808e3f89b28… │ │ 2318: │ │ │ status='queued', │ │ 2319: │ │ │ input={'test': 'test'}, │ │ 2320: │ │ │ output=None, │ │ 2321: │ │ │ error=None, │ │ 2322: │ │ │ transition_count=None, │ │ ... 2357: │ │ │ │ │ 2358: │ │ developer_id=UUID('00000000-0000-0000-0000-000000… │ │ 2359: │ │ │ │ │ 2360: │ │ agent_id=UUID('0682c7bd-a9ec-78c1-8000-606c8c05f7… │ │ 2361: │ │ │ version=1 │ │ 2362: │ │ ) │ │ 2363: │ │ workflow_handle = <temporalio.client.WorkflowHandle object at │ │ 2364: │ │ 0x7f984d287110> │ │ 2365: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 2366: │ │ 2367: │ /home/runner/work/julep/julep/agents-api/agents_api/queries/utils.py:319 │ 2368: │ in async_wrapper │ 2369: │ │ 2370: │ 316 │ │ │ try: │ 2371: │ 317 │ │ │ │ result: T = await func(*args, **kwargs) │ 2372: │ 318 │ │ │ except BaseException as error: │ 2373: │ ❱ 319 │ │ │ │ _check_error(error) │ 2374: │ 320 │ │ │ │ raise error │ 2375: │ 321 │ │ │ │ ... 2399: │ │ │ │ │ step=0, │ │ 2400: │ │ │ │ │ │ │ 2401: │ │ scope_id=UUID('0682c7bd-acfc-7720-8000-8cd2c0f05064') │ │ 2402: │ │ │ │ ), │ │ 2403: │ │ │ │ step_label=None, │ │ 2404: │ │ │ │ id=None, │ │ 2405: │ │ │ │ metadata=None, │ │ 2406: │ │ │ │ task_token=None │ │ 2407: │ │ │ ), │ │ 2408: │ │ │ 'connection_pool': <asyncpg.pool.Pool object at │ │ 2409: │ │ 0x7f984d6dc400> │ │ 2410: │ │ } │ │ 2411: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 2412: │ │ 2413: │ /home/runner/work/julep/julep/agents-api/agents_api/queries/utils.py:309 │ 2414: │ in _check_error │ 2415: │ │ 2416: │ 306 │ │ │ │ setattr(new_error, "__cause__", error) │ 2417: │ 307 │ │ │ │ │ 2418: │ 308 │ │ │ │ print(error) │ 2419: │ ❱ 309 │ │ │ │ raise new_error from error │ 2420: │ 310 │ │ 2421: │ 311 │ def decorator( │ 2422: │ 312 │ │ func: Callable[P, T | Awaitable[T]], │ 2423: │ │ 2424: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 2425: │ │ error = TypeError("create_execution_transition() got an │ │ 2426: │ │ unexpected keyword argument 'developer_id'") │ │ 2427: │ │ mapping = { │ │ 2428: │ │ │ <function common_db_exceptions.<locals>.<lambda> │ │ 2429: │ │ at 0x7f98700d5580>: <class │ │ 2430: │ │ 'fastapi.exceptions.HTTPException'>, │ │ 2431: │ │ │ <function common_db_exceptions.<locals>.<lambda> │ │ 2432: │ │ at 0x7f98700d56c0>: <function │ │ 2433: │ │ common_db_exceptions.<locals>._invalid_reference_err… │ │ 2434: │ │ at 0x7f98700d54e0>, │ │ 2435: │ │ │ <class │ │ 2436: │ │ 'asyncpg.exceptions.ForeignKeyViolationError'>: │ │ 2437: │ │ <class 'fastapi.exceptions.HTTPException'>, │ │ 2438: │ │ │ <class │ │ 2439: │ │ 'asyncpg.exceptions.UniqueViolationError'>: <class │ │ 2440: │ │ 'fastapi.exceptions.HTTPException'>, │ │ 2441: │ │ │ <class 'asyncpg.exceptions.CheckViolationError'>: │ │ 2442: │ │ <class 'fastapi.exceptions.HTTPException'>, │ │ 2443: │ │ │ <class 'asyncpg.exceptions.DataError'>: <class │ │ 2444: │ │ 'fastapi.exceptions.HTTPException'>, │ │ 2445: │ │ │ <class 'asyncpg.exceptions.NoDataFoundError'>: │ │ 2446: │ │ <class 'fastapi.exceptions.HTTPException'>, │ │ 2447: │ │ │ <class 'socket.gaierror'>: <class │ │ 2448: │ │ 'fastapi.exceptions.HTTPException'>, │ │ 2449: │ │ │ <class │ │ 2450: │ │ 'asyncpg.exceptions.InvalidTextRepresentationError'>: │ │ 2451: │ │ <class 'fastapi.exceptions.HTTPException'>, │ │ 2452: │ │ │ <class │ │ 2453: │ │ 'asyncpg.exceptions.NumericValueOutOfRangeError'>: │ │ 2454: │ │ <class 'fastapi.exceptions.HTTPException'>, │ │ 2455: │ │ │ ... +11 │ │ 2456: │ │ } │ │ 2457: │ │ new_error = HTTPException(status_code=400, detail='Invalid type │ │ 2458: │ │ for transition during create') │ │ ... 2579: │ │ make_request.<locals>._make_request at 0x7f984d68c900> │ │ 2580: │ │ │ │ │ │ ), │ │ 2581: │ │ │ │ │ │ │ │ 2582: │ │ '/home/runner/work/julep/julep/agents-api/tests/fixtures.py… │ │ 2583: │ │ Fixture( │ │ 2584: │ │ │ │ │ │ │ fn=<function test_execution at │ │ 2585: │ │ 0x7f986ea9f420>, │ │ 2586: │ │ │ │ │ │ │ gen=<async_generator object │ │ 2587: │ │ test_execution at 0x7f983fb97de0>, │ │ 2588: │ │ │ │ │ │ │ resolved_val=Execution( │ │ 2589: │ │ │ │ │ │ │ │ │ │ 2590: │ │ task_id=UUID('0682c7bd-9b48-7f92-8000-80cadc105c9e'), │ │ 2591: │ │ │ │ │ │ │ │ status='queued', │ │ 2592: │ │ │ │ │ │ │ │ input={'test': 'test'}, │ │ 2593: │ │ │ │ │ │ │ │ output=None, │ │ 2594: │ │ │ │ │ │ │ │ error=None, │ │ 2595: │ │ │ │ │ │ │ │ transition_count=None, │ │ ... 2783: │ │ │ │ │ │ │ │ 2784: │ │ '/home/runner/work/julep/julep/agents-api/test… │ │ 2785: │ │ Fixture( │ │ 2786: │ │ │ │ │ │ │ fn=<function test_execution │ │ 2787: │ │ at 0x7f986ea9f420>, │ │ 2788: │ │ │ │ │ │ │ gen=<async_generator object │ │ 2789: │ │ test_execution at 0x7f983fb97de0>, │ │ 2790: │ │ │ │ │ │ │ resolved_val=Execution( │ │ 2791: │ │ │ │ │ │ │ │ │ │ 2792: │ │ task_id=UUID('0682c7bd-9b48-7f92-8000-80cadc10… │ │ 2793: │ │ │ │ │ │ │ │ status='queued', │ │ 2794: │ │ │ │ │ │ │ │ input={ │ │ 2795: │ │ │ │ │ │ │ │ │ 'test': 'test' │ │ 2796: │ │ │ │ │ │ │ │ }, │ │ 2797: │ │ │ │ │ │ │ │ output=None, │ │ 2798: │ │ │ │ │ │ │ │ error=None, │ │ 2799: │ │ │ │ │ │ │ │ transition_count=None, │ │ ... 2863: │ │ │ │ ), │ │ 2864: │ │ │ │ timer=<ward._testing._Timer object at │ │ 2865: │ │ 0x7f984d25e480>, │ │ 2866: │ │ │ │ tags=[] │ │ 2867: │ │ │ ), │ │ 2868: │ │ │ iteration=0 │ │ 2869: │ │ ) │ │ 2870: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 2871: │ │ 2872: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 2873: │ ges/ward/testing.py:637 in _resolve_single_arg │ 2874: │ │ 2875: │ 634 │ │ │ else: │ 2876: │ 635 │ │ │ │ fixture.resolved_val = arg(**args_to_inject) │ 2877: │ 636 │ │ except (Exception, SystemExit) as e: │ 2878: │ ❱ 637 │ │ │ raise FixtureError(f"Unable to resolve fixture '{fixtu │ 2879: │ 638 │ │ scope_key = self.test.scope_key_from(fixture.scope) │ ... 3045: │ │ 0x7f984d68c900> │ │ 3046: │ │ │ │ │ │ ), │ │ 3047: │ │ │ │ │ │ │ │ 3048: │ │ '/home/runner/work/julep/julep/agents-api/tests… │ │ 3049: │ │ Fixture( │ │ 3050: │ │ │ │ │ │ │ fn=<function test_execution │ │ 3051: │ │ at 0x7f986ea9f420>, │ │ 3052: │ │ │ │ │ │ │ gen=<async_generator object │ │ 3053: │ │ test_execution at 0x7f983fb97de0>, │ │ 3054: │ │ │ │ │ │ │ resolved_val=Execution( │ │ 3055: │ │ │ │ │ │ │ │ │ │ 3056: │ │ task_id=UUID('0682c7bd-9b48-7f92-8000-80cadc105… │ │ 3057: │ │ │ │ │ │ │ │ status='queued', │ │ 3058: │ │ │ │ │ │ │ │ input={'test': 'test'}, │ │ 3059: │ │ │ │ │ │ │ │ output=None, │ │ 3060: │ │ │ │ │ │ │ │ error=None, │ │ 3061: │ │ │ │ │ │ │ │ transition_count=None, │ │ ... 3179: │ │ │ │ │ description=None, │ │ 3180: │ │ │ │ │ tags=None, │ │ 3181: │ │ │ │ │ is_fixture=False, │ │ 3182: │ │ │ │ │ scope=<Scope.Test: 'test'>, │ │ 3183: │ │ │ │ │ bound_args=None, │ │ 3184: │ │ │ │ │ path=None │ │ 3185: │ │ │ │ ), │ │ 3186: │ │ │ │ timer=<ward._testing._Timer object at │ │ 3187: │ │ 0x7f984d25e480>, │ │ 3188: │ │ │ │ tags=[] │ │ 3189: │ │ │ ), │ │ 3190: │ │ │ iteration=0 │ │ 3191: │ │ ) │ │ 3192: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 3193: ╰──────────────────────────────────────────────────────────────────────────╯ 3194: FixtureError: Unable to resolve fixture 'test_execution_started' 3195: Captured stdout 3196: create_execution_transition() got an unexpected keyword argument 3197: 'developer_id' 3198: ─────────────────────────── query: count executions ──────────────────────────── 3199: Failed at tests/test_execution_queries.py 3200: ╭─────────────────── Traceback (most recent call last) ────────────────────╮ 3201: │ /home/runner/work/julep/julep/agents-api/agents_api/queries/utils.py:317 │ 3202: │ in async_wrapper │ 3203: │ │ 3204: │ 314 │ │ @wraps(func) │ 3205: │ 315 │ │ async def async_wrapper(*args: P.args, **kwargs: P.kwargs) │ 3206: │ 316 │ │ │ try: │ 3207: │ ❱ 317 │ │ │ │ result: T = await func(*args, **kwargs) │ 3208: │ 318 │ │ │ except BaseException as error: │ 3209: │ 319 │ │ │ │ _check_error(error) │ 3210: │ 320 │ │ │ │ raise error │ 3211: │ │ ... 3337: │ │ 0x7f983e9aa800> │ │ 3338: │ │ } │ │ 3339: │ │ metric_label = 'create_execution_transition' │ │ 3340: │ │ start_time = 1747745758.6153033 │ │ 3341: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 3342: │ │ 3343: │ /home/runner/work/julep/julep/agents-api/agents_api/queries/utils.py:117 │ 3344: │ in wrapper │ 3345: │ │ 3346: │ 114 │ │ │ connection_pool: asyncpg.Pool | None = None, │ 3347: │ 115 │ │ │ **kwargs: P.kwargs, │ 3348: │ 116 │ │ ) -> list[Record]: │ 3349: │ ❱ 117 │ │ │ query_args = await func(*args, **kwargs) │ 3350: │ 118 │ │ │ batch = prepare_pg_query_args(query_args) │ 3351: │ 119 │ │ │ │ 3352: │ 120 │ │ │ not only_on_error and debug and pprint(batch) │ 3353: │ │ ... 3372: │ │ │ │ │ │ │ 3373: │ │ scope_id=UUID('0682c7bd-e705-7695-8000-a4fccd457e… │ │ 3374: │ │ │ │ ), │ │ 3375: │ │ │ │ next=TransitionTarget( │ │ 3376: │ │ │ │ │ workflow='main', │ │ 3377: │ │ │ │ │ step=0, │ │ 3378: │ │ │ │ │ │ │ 3379: │ │ scope_id=UUID('0682c7bd-e705-7695-8000-a4fccd457e… │ │ 3380: │ │ │ │ ), │ │ 3381: │ │ │ │ step_label=None, │ │ 3382: │ │ │ │ id=None, │ │ 3383: │ │ │ │ metadata=None, │ │ 3384: │ │ │ │ task_token=None │ │ 3385: │ │ │ ) │ │ 3386: │ │ } │ │ 3387: │ │ only_on_error = False │ │ 3388: │ │ return_index = -1 │ │ ... 3410: │ │ │ │ ), │ │ 3411: │ │ │ │ next=TransitionTarget( │ │ 3412: │ │ │ │ │ workflow='main', │ │ 3413: │ │ │ │ │ step=0, │ │ 3414: │ │ │ │ │ │ │ 3415: │ │ scope_id=UUID('0682c7bd-e705-7695-8000-a4fccd457ec4') │ │ 3416: │ │ │ │ ), │ │ 3417: │ │ │ │ step_label=None, │ │ 3418: │ │ │ │ id=None, │ │ 3419: │ │ │ │ metadata=None, │ │ 3420: │ │ │ │ task_token=None │ │ 3421: │ │ │ ) │ │ 3422: │ │ } │ │ 3423: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 3424: ╰──────────────────────────────────────────────────────────────────────────╯ 3425: TypeError: create_execution_transition() got an unexpected keyword argument 3426: 'developer_id' ... 3603: │ │ 0x7f984d68c900> │ │ 3604: │ │ │ │ │ │ ), │ │ 3605: │ │ │ │ │ │ │ │ 3606: │ │ '/home/runner/work/julep/julep/agents-api/tests… │ │ 3607: │ │ Fixture( │ │ 3608: │ │ │ │ │ │ │ fn=<function test_execution │ │ 3609: │ │ at 0x7f986ea9f420>, │ │ 3610: │ │ │ │ │ │ │ gen=<async_generator object │ │ 3611: │ │ test_execution at 0x7f983fb97de0>, │ │ 3612: │ │ │ │ │ │ │ resolved_val=Execution( │ │ 3613: │ │ │ │ │ │ │ │ │ │ 3614: │ │ task_id=UUID('0682c7bd-9b48-7f92-8000-80cadc105… │ │ 3615: │ │ │ │ │ │ │ │ status='queued', │ │ 3616: │ │ │ │ │ │ │ │ input={'test': 'test'}, │ │ 3617: │ │ │ │ │ │ │ │ output=None, │ │ 3618: │ │ │ │ │ │ │ │ error=None, │ │ 3619: │ │ │ │ │ │ │ │ transition_count=None, │ │ ... 3763: │ │ 3764: │ ╭───────────────────────────── locals ─────────────────────────────╮ │ 3765: │ │ debug = None │ │ 3766: │ │ loop_factory = None │ │ 3767: │ │ main = <async_generator_asend object at 0x7f984d507900> │ │ 3768: │ │ runner = <asyncio.runners.Runner object at 0x7f984d2d07d0> │ │ 3769: │ ╰──────────────────────────────────────────────────────────────────╯ │ 3770: │ │ 3771: │ /home/runner/.local/share/uv/python/cpython-3.12.10-linux-x86_64-gnu/lib │ 3772: │ /python3.12/asyncio/runners.py:118 in run │ 3773: │ │ 3774: │ 115 │ │ │ 3775: │ 116 │ │ self._interrupt_count = 0 │ 3776: │ 117 │ │ try: │ 3777: │ ❱ 118 │ │ │ return self._loop.run_until_complete(task) │ 3778: │ 119 │ │ except exceptions.CancelledError: │ 3779: │ 120 │ │ │ if self._interrupt_count > 0: │ ... 3809: │ ❱ 390 │ await create_execution_transition( │ 3810: │ 391 │ │ developer_id=developer_id, │ 3811: │ 392 │ │ execution_id=execution.id, │ 3812: │ 393 │ │ data=CreateTransitionRequest( │ 3813: │ │ 3814: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 3815: │ │ actual_scope_id = UUID('0682c7bd-e705-7695-8000-a4fccd457ec4') │ │ 3816: │ │ developer_id = UUID('00000000-0000-0000-0000-000000000000') │ │ 3817: │ │ dsn = '***localhost:32769/test?sslmod… │ │ 3818: │ │ execution = Execution( │ │ 3819: │ │ │ │ │ 3820: │ │ task_id=UUID('0682c7bd-e6cd-7964-8000-0f7476e9150… │ │ 3821: │ │ │ status='queued', │ │ 3822: │ │ │ input={'test': 'test'}, │ │ 3823: │ │ │ output=None, │ │ 3824: │ │ │ error=None, │ │ 3825: │ │ │ transition_count=None, │ │ ... 3860: │ │ │ │ │ 3861: │ │ developer_id=UUID('00000000-0000-0000-0000-000000… │ │ 3862: │ │ │ │ │ 3863: │ │ agent_id=UUID('0682c7bd-e403-757e-8000-172beceacd… │ │ 3864: │ │ │ version=1 │ │ 3865: │ │ ) │ │ 3866: │ │ workflow_handle = <temporalio.client.WorkflowHandle object at │ │ 3867: │ │ 0x7f984d2d2f90> │ │ 3868: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 3869: │ │ 3870: │ /home/runner/work/julep/julep/agents-api/agents_api/queries/utils.py:319 │ 3871: │ in async_wrapper │ 3872: │ │ 3873: │ 316 │ │ │ try: │ 3874: │ 317 │ │ │ │ result: T = await func(*args, **kwargs) │ 3875: │ 318 │ │ │ except BaseException as error: │ 3876: │ ❱ 319 │ │ │ │ _check_error(error) │ 3877: │ 320 │ │ │ │ raise error │ 3878: │ 321 │ │ │ │ ... 3902: │ │ │ │ │ step=0, │ │ 3903: │ │ │ │ │ │ │ 3904: │ │ scope_id=UUID('0682c7bd-e705-7695-8000-a4fccd457ec4') │ │ 3905: │ │ │ │ ), │ │ 3906: │ │ │ │ step_label=None, │ │ 3907: │ │ │ │ id=None, │ │ 3908: │ │ │ │ metadata=None, │ │ 3909: │ │ │ │ task_token=None │ │ 3910: │ │ │ ), │ │ 3911: │ │ │ 'connection_pool': <asyncpg.pool.Pool object at │ │ 3912: │ │ 0x7f983e9aa800> │ │ 3913: │ │ } │ │ 3914: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 3915: │ │ 3916: │ /home/runner/work/julep/julep/agents-api/agents_api/queries/utils.py:309 │ 3917: │ in _check_error │ 3918: │ │ 3919: │ 306 │ │ │ │ setattr(new_error, "__cause__", error) │ 3920: │ 307 │ │ │ │ │ 3921: │ 308 │ │ │ │ print(error) │ 3922: │ ❱ 309 │ │ │ │ raise new_error from error │ 3923: │ 310 │ │ 3924: │ 311 │ def decorator( │ 3925: │ 312 │ │ func: Callable[P, T | Awaitable[T]], │ 3926: │ │ 3927: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 3928: │ │ error = TypeError("create_execution_transition() got an │ │ 3929: │ │ unexpected keyword argument 'developer_id'") │ │ 3930: │ │ mapping = { │ │ 3931: │ │ │ <function common_db_exceptions.<locals>.<lambda> │ │ 3932: │ │ at 0x7f98700d5580>: <class │ │ 3933: │ │ 'fastapi.exceptions.HTTPException'>, │ │ 3934: │ │ │ <function common_db_exceptions.<locals>.<lambda> │ │ 3935: │ │ at 0x7f98700d56c0>: <function │ │ 3936: │ │ common_db_exceptions.<locals>._invalid_reference_err… │ │ 3937: │ │ at 0x7f98700d54e0>, │ │ 3938: │ │ │ <class │ │ 3939: │ │ 'asyncpg.exceptions.ForeignKeyViolationError'>: │ │ 3940: │ │ <class 'fastapi.exceptions.HTTPException'>, │ │ 3941: │ │ │ <class │ │ 3942: │ │ 'asyncpg.exceptions.UniqueViolationError'>: <class │ │ 3943: │ │ 'fastapi.exceptions.HTTPException'>, │ │ 3944: │ │ │ <class 'asyncpg.exceptions.CheckViolationError'>: │ │ 3945: │ │ <class 'fastapi.exceptions.HTTPException'>, │ │ 3946: │ │ │ <class 'asyncpg.exceptions.DataError'>: <class │ │ 3947: │ │ 'fastapi.exceptions.HTTPException'>, │ │ 3948: │ │ │ <class 'asyncpg.exceptions.NoDataFoundError'>: │ │ 3949: │ │ <class 'fastapi.exceptions.HTTPException'>, │ │ 3950: │ │ │ <class 'socket.gaierror'>: <class │ │ 3951: │ │ 'fastapi.exceptions.HTTPException'>, │ │ 3952: │ │ │ <class │ │ 3953: │ │ 'asyncpg.exceptions.InvalidTextRepresentationError'>: │ │ 3954: │ │ <class 'fastapi.exceptions.HTTPException'>, │ │ 3955: │ │ │ <class │ │ 3956: │ │ 'asyncpg.exceptions.NumericValueOutOfRangeError'>: │ │ 3957: │ │ <class 'fastapi.exceptions.HTTPException'>, │ │ 3958: │ │ │ ... +11 │ │ 3959: │ │ } │ │ 3960: │ │ new_error = HTTPException(status_code=400, detail='Invalid type │ │ 3961: │ │ for transition during create') │ │ ... 4082: │ │ make_request.<locals>._make_request at 0x7f984d68c900> │ │ 4083: │ │ │ │ │ │ ), │ │ 4084: │ │ │ │ │ │ │ │ 4085: │ │ '/home/runner/work/julep/julep/agents-api/tests/fixtures.py… │ │ 4086: │ │ Fixture( │ │ 4087: │ │ │ │ │ │ │ fn=<function test_execution at │ │ 4088: │ │ 0x7f986ea9f420>, │ │ 4089: │ │ │ │ │ │ │ gen=<async_generator object │ │ 4090: │ │ test_execution at 0x7f983fb97de0>, │ │ 4091: │ │ │ │ │ │ │ resolved_val=Execution( │ │ 4092: │ │ │ │ │ │ │ │ │ │ 4093: │ │ task_id=UUID('0682c7bd-9b48-7f92-8000-80cadc105c9e'), │ │ 4094: │ │ │ │ │ │ │ │ status='queued', │ │ 4095: │ │ │ │ │ │ │ │ input={'test': 'test'}, │ │ 4096: │ │ │ │ │ │ │ │ output=None, │ │ 4097: │ │ │ │ │ │ │ │ error=None, │ │ 4098: │ │ │ │ │ │ │ │ transition_count=None, │ │ ... 4286: │ │ │ │ │ │ │ │ 4287: │ │ '/home/runner/work/julep/julep/agents-api/test… │ │ 4288: │ │ Fixture( │ │ 4289: │ │ │ │ │ │ │ fn=<function test_execution │ │ 4290: │ │ at 0x7f986ea9f420>, │ │ 4291: │ │ │ │ │ │ │ gen=<async_generator object │ │ 4292: │ │ test_execution at 0x7f983fb97de0>, │ │ 4293: │ │ │ │ │ │ │ resolved_val=Execution( │ │ 4294: │ │ │ │ │ │ │ │ │ │ 4295: │ │ task_id=UUID('0682c7bd-9b48-7f92-8000-80cadc10… │ │ 4296: │ │ │ │ │ │ │ │ status='queued', │ │ 4297: │ │ │ │ │ │ │ │ input={ │ │ 4298: │ │ │ │ │ │ │ │ │ 'test': 'test' │ │ 4299: │ │ │ │ │ │ │ │ }, │ │ 4300: │ │ │ │ │ │ │ │ output=None, │ │ 4301: │ │ │ │ │ │ │ │ error=None, │ │ 4302: │ │ │ │ │ │ │ │ transition_count=None, │ │ ... 4366: │ │ │ │ ), │ │ 4367: │ │ │ │ timer=<ward._testing._Timer object at │ │ 4368: │ │ 0x7f984d2a8bf0>, │ │ 4369: │ │ │ │ tags=[] │ │ 4370: │ │ │ ), │ │ 4371: │ │ │ iteration=0 │ │ 4372: │ │ ) │ │ 4373: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 4374: │ │ 4375: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 4376: │ ges/ward/testing.py:637 in _resolve_single_arg │ 4377: │ │ 4378: │ 634 │ │ │ else: │ 4379: │ 635 │ │ │ │ fixture.resolved_val = arg(**args_to_inject) │ 4380: │ 636 │ │ except (Exception, SystemExit) as e: │ 4381: │ ❱ 637 │ │ │ raise FixtureError(f"Unable to resolve fixture '{fixtu │ 4382: │ 638 │ │ scope_key = self.test.scope_key_from(fixture.scope) │ ... 4549: │ │ 0x7f984d68c900> │ │ 4550: │ │ │ │ │ │ ), │ │ 4551: │ │ │ │ │ │ │ │ 4552: │ │ '/home/runner/work/julep/julep/agents-api/tests… │ │ 4553: │ │ Fixture( │ │ 4554: │ │ │ │ │ │ │ fn=<function test_execution │ │ 4555: │ │ at 0x7f986ea9f420>, │ │ 4556: │ │ │ │ │ │ │ gen=<async_generator object │ │ 4557: │ │ test_execution at 0x7f983fb97de0>, │ │ 4558: │ │ │ │ │ │ │ resolved_val=Execution( │ │ 4559: │ │ │ │ │ │ │ │ │ │ 4560: │ │ task_id=UUID('0682c7bd-9b48-7f92-8000-80cadc105… │ │ 4561: │ │ │ │ │ │ │ │ status='queued', │ │ 4562: │ │ │ │ │ │ │ │ input={'test': 'test'}, │ │ 4563: │ │ │ │ │ │ │ │ output=None, │ │ 4564: │ │ │ │ │ │ │ │ error=None, │ │ 4565: │ │ │ │ │ │ │ │ transition_count=None, │ │ ... 4684: │ │ │ │ │ description=None, │ │ 4685: │ │ │ │ │ tags=None, │ │ 4686: │ │ │ │ │ is_fixture=False, │ │ 4687: │ │ │ │ │ scope=<Scope.Test: 'test'>, │ │ 4688: │ │ │ │ │ bound_args=None, │ │ 4689: │ │ │ │ │ path=None │ │ 4690: │ │ │ │ ), │ │ 4691: │ │ │ │ timer=<ward._testing._Timer object at │ │ 4692: │ │ 0x7f984d2a8bf0>, │ │ 4693: │ │ │ │ tags=[] │ │ 4694: │ │ │ ), │ │ 4695: │ │ │ iteration=0 │ │ 4696: │ │ ) │ │ 4697: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 4698: ╰──────────────────────────────────────────────────────────────────────────╯ 4699: FixtureError: Unable to resolve fixture 'test_execution_started' 4700: Captured stdout 4701: create_execution_transition() got an unexpected keyword argument 4702: 'developer_id' 4703: ────────────────────── query: create execution transition ────────────────────── 4704: Failed at tests/test_execution_queries.py 4705: ╭─────────────────── Traceback (most recent call last) ────────────────────╮ 4706: │ /home/runner/work/julep/julep/agents-api/agents_api/queries/utils.py:317 │ 4707: │ in async_wrapper │ 4708: │ │ 4709: │ 314 │ │ @wraps(func) │ 4710: │ 315 │ │ async def async_wrapper(*args: P.args, **kwargs: P.kwargs) │ 4711: │ 316 │ │ │ try: │ 4712: │ ❱ 317 │ │ │ │ result: T = await func(*args, **kwargs) │ 4713: │ 318 │ │ │ except BaseException as error: │ 4714: │ 319 │ │ │ │ _check_error(error) │ 4715: │ 320 │ │ │ │ raise error │ 4716: │ │ ... 4842: │ │ 0x7f983e9aad40> │ │ 4843: │ │ } │ │ 4844: │ │ metric_label = 'create_execution_transition' │ │ 4845: │ │ start_time = 1747745758.7870736 │ │ 4846: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 4847: │ │ 4848: │ /home/runner/work/julep/julep/agents-api/agents_api/queries/utils.py:117 │ 4849: │ in wrapper │ 4850: │ │ 4851: │ 114 │ │ │ connection_pool: asyncpg.Pool | None = None, │ 4852: │ 115 │ │ │ **kwargs: P.kwargs, │ 4853: │ 116 │ │ ) -> list[Record]: │ 4854: │ ❱ 117 │ │ │ query_args = await func(*args, **kwargs) │ 4855: │ 118 │ │ │ batch = prepare_pg_query_args(query_args) │ 4856: │ 119 │ │ │ │ 4857: │ 120 │ │ │ not only_on_error and debug and pprint(batch) │ 4858: │ │ ... 4877: │ │ │ │ │ │ │ 4878: │ │ scope_id=UUID('0682c7bd-ec97-789a-8000-83571fe01f… │ │ 4879: │ │ │ │ ), │ │ 4880: │ │ │ │ next=TransitionTarget( │ │ 4881: │ │ │ │ │ workflow='main', │ │ 4882: │ │ │ │ │ step=0, │ │ 4883: │ │ │ │ │ │ │ 4884: │ │ scope_id=UUID('0682c7bd-ec97-789a-8000-83571fe01f… │ │ 4885: │ │ │ │ ), │ │ 4886: │ │ │ │ step_label=None, │ │ 4887: │ │ │ │ id=None, │ │ 4888: │ │ │ │ metadata=None, │ │ 4889: │ │ │ │ task_token=None │ │ 4890: │ │ │ ) │ │ 4891: │ │ } │ │ 4892: │ │ only_on_error = False │ │ 4893: │ │ return_index = -1 │ │ ... 4915: │ │ │ │ ), │ │ 4916: │ │ │ │ next=TransitionTarget( │ │ 4917: │ │ │ │ │ workflow='main', │ │ 4918: │ │ │ │ │ step=0, │ │ 4919: │ │ │ │ │ │ │ 4920: │ │ scope_id=UUID('0682c7bd-ec97-789a-8000-83571fe01f14') │ │ 4921: │ │ │ │ ), │ │ 4922: │ │ │ │ step_label=None, │ │ 4923: │ │ │ │ id=None, │ │ 4924: │ │ │ │ metadata=None, │ │ 4925: │ │ │ │ task_token=None │ │ 4926: │ │ │ ) │ │ 4927: │ │ } │ │ 4928: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 4929: ╰──────────────────────────────────────────────────────────────────────────╯ 4930: TypeError: create_execution_transition() got an unexpected keyword argument 4931: 'developer_id' ... 4944: │ │ 4945: │ ╭───────────────────────────── locals ─────────────────────────────╮ │ 4946: │ │ debug = None │ │ 4947: │ │ loop_factory = None │ │ 4948: │ │ main = <coroutine object _ at 0x7f984d6c1f80> │ │ 4949: │ │ runner = <asyncio.runners.Runner object at 0x7f984d2cd3a0> │ │ 4950: │ ╰──────────────────────────────────────────────────────────────────╯ │ 4951: │ │ 4952: │ /home/runner/.local/share/uv/python/cpython-3.12.10-linux-x86_64-gnu/lib │ 4953: │ /python3.12/asyncio/runners.py:118 in run │ 4954: │ │ 4955: │ 115 │ │ │ 4956: │ 116 │ │ self._interrupt_count = 0 │ 4957: │ 117 │ │ try: │ 4958: │ ❱ 118 │ │ │ return self._loop.run_until_complete(task) │ 4959: │ 119 │ │ except exceptions.CancelledError: │ 4960: │ 120 │ │ │ if self._interrupt_count > 0: │ ... 4990: │ 220 │ scope_id = uuid7() │ 4991: │ ❱ 221 │ result = await create_execution_transition( │ 4992: │ 222 │ │ developer_id=developer_id, │ 4993: │ 223 │ │ execution_id=execution.id, │ 4994: │ 224 │ │ data=CreateTransitionRequest( │ 4995: │ │ 4996: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 4997: │ │ developer_id = UUID('00000000-0000-0000-0000-000000000000') │ │ 4998: │ │ dsn = '***localhost:32769/test?sslmode=d… │ │ 4999: │ │ execution = Execution( │ │ 5000: │ │ │ │ │ 5001: │ │ task_id=UUID('0682c7bd-9b48-7f92-8000-80cadc105c9e'), │ │ 5002: │ │ │ status='queued', │ │ 5003: │ │ │ input={'test': 'test'}, │ │ 5004: │ │ │ output=None, │ │ 5005: │ │ │ error=None, │ │ 5006: │ │ │ transition_count=None, │ │ ... 5008: │ │ 53, 890040, tzinfo=datetime.timezone.utc), │ │ 5009: │ │ │ updated_at=datetime.datetime(2025, 5, 20, 12, 55, │ │ 5010: │ │ 53, 893367, tzinfo=datetime.timezone.utc), │ │ 5011: │ │ │ metadata={}, │ │ 5012: │ │ │ id=UUID('0682c7bd-9e3c-7cd2-8000-9dde30ba2651') │ │ 5013: │ │ ) │ │ 5014: │ │ pool = <asyncpg.pool.Pool object at 0x7f983e9aad40> │ │ 5015: │ │ scope_id = UUID('0682c7bd-ec97-789a-8000-83571fe01f14') ...