fix(agents-api): Configure spacy for postgresql

[Ahmad-mtos]

PR Type

Enhancement, Tests, Bug fix

---

Description

• Refactored and enhanced text_to_tsvector_query for improved keyword extraction.

• Removed unused and redundant methods like find_proximity_groups and KeywordMatcher.

• Added new test cases for text_to_tsvector_query and extract_keywords.

• Integrated text_to_tsvector_query into search_docs_by_text and search_docs_hybrid.

---

Changes walkthrough 📝

	Relevant files
Enhancement	nlp.py Refactored and optimized NLP utilities                                      agents-api/agents_api/common/nlp.py Refactored text_to_tsvector_query to simplify and optimize keyword extraction. Removed find_proximity_groups and KeywordMatcher for better performance. Enhanced clean_keyword to handle lone hyphens and multiple spaces. Added split_chunks option to extract_keywords for finer control. +92/-179 search_docs_by_text.py Integrated `text_to_tsvector_query` in text search              agents-api/agents_api/queries/docs/search_docs_by_text.py Integrated text_to_tsvector_query for preprocessing raw text queries. Simplified query handling logic. +2/-1      search_docs_hybrid.py Added `text_to_tsvector_query` to hybrid search                    agents-api/agents_api/queries/docs/search_docs_hybrid.py Integrated text_to_tsvector_query for preprocessing raw text queries. Improved query handling for hybrid search. +4/-0
Tests	test_docs_queries.py Removed outdated `text_to_tsvector_query` tests                    agents-api/tests/test_docs_queries.py Removed outdated tests for text_to_tsvector_query. Simplified test structure for document queries. +0/-64    test_nlp_utilities.py Added tests for NLP utility functions                                        agents-api/tests/test_nlp_utilities.py Added comprehensive tests for clean_keyword, extract_keywords, and text_to_tsvector_query. Covered edge cases and new split_chunks functionality. +156/-0

---

💡 PR-Agent usage: Comment /help "your question" on any pull request to receive relevant information

---

Important

Refactor and enhance NLP utilities for improved keyword extraction and query processing, integrating changes into search functions and adding comprehensive tests.

• Behavior:
  • Refactored text_to_tsvector_query in nlp.py for improved keyword extraction and query processing.
  • Integrated text_to_tsvector_query into search_docs_by_text and search_docs_hybrid for preprocessing queries.
  • Removed find_proximity_groups and KeywordMatcher for performance improvement.
• Enhancements:
  • Enhanced clean_keyword to handle lone hyphens and multiple spaces.
  • Added split_chunks option to extract_keywords for finer control.
• Tests:
  • Added tests for clean_keyword, extract_keywords, and text_to_tsvector_query in test_nlp_utilities.py.
  • Removed outdated tests for text_to_tsvector_query in test_docs_queries.py.

^{This description was created by for fcd2ad3. It will automatically update as commits are pushed.}

[qodo-merge-pro-for-open-source]

CI Failure Feedback 🧐

(Checks updated until commit fcd2ad3)

Action: Test

Failed stage: Run tests [❌]

Failed test name: test_agent_routes

Failure summary: The action failed because of a database connection pool configuration error. Specifically, the min_size (10) was set larger than the max_size (4) in the AsyncPG connection pool initialization, which is invalid. This caused the test fixtures to fail when trying to establish database connections, affecting multiple test cases in test_agent_routes.py. Key failures: ValueError: "min_size is greater than max_size" Unable to resolve fixture 'client' due to database connection failure 3 out of 12 tests failed (25% failure rate)

Relevant error logs: 1: ##[group]Operating System 2: Ubuntu ... 1327: PASS test_agent_queries:28 query: create agent sql 1% 1328: PASS test_agent_queries:44 query: create or update agent sql 2% 1329: PASS test_agent_queries:63 query: update agent sql 2% 1330: PASS test_agent_queries:85 query: get agent not exists sql 3% 1331: PASS test_agent_queries:96 query: get agent exists sql 3% 1332: PASS test_agent_queries:111 query: list agents sql 4% 1333: PASS test_agent_queries:122 query: patch agent sql 4% 1334: PASS test_agent_queries:143 query: delete agent sql 5% 1335: FAIL test_agent_routes:9 route: unauthorized should fail 5% 1336: FAIL test_agent_routes:26 route: create agent 6% 1337: FAIL test_agent_routes:43 route: create agent with instructions 7% 1338: ─────────────────────── route: unauthorized should fail ──────────────────────── 1339: Failed at tests/test_agent_routes.py ... 1460: │ │ name = '_dsn' │ │ 1461: │ │ self = TestArgumentResolver( │ │ 1462: │ │ │ test=Test( │ │ 1463: │ │ │ │ fn=<function _ at 0x7fab41046980>, │ │ 1464: │ │ │ │ module_name='test_agent_routes', │ │ 1465: │ │ │ │ id='a4d0131e9e4e4176a0e1fda69aa5b577', │ │ 1466: │ │ │ │ marker=None, │ │ 1467: │ │ │ │ description='route: unauthorized should │ │ 1468: │ │ fail', │ │ ... 1587: │ │ self = <anyio._backends._asyncio.BlockingPortal object at │ │ 1588: │ │ 0x7fab4158ed20> │ │ 1589: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 1590: │ │ 1591: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 1592: │ python3.12/concurrent/futures/_base.py:456 in result │ 1593: │ │ 1594: │ 453 │ │ │ │ if self._state in [CANCELLED, CANCELLED_AND_NOTIFI │ 1595: │ 454 │ │ │ │ │ raise CancelledError() │ 1596: │ 455 │ │ │ │ elif self._state == FINISHED: │ 1597: │ ❱ 456 │ │ │ │ │ return self.__get_result() │ 1598: │ 457 │ │ │ │ else: │ 1599: │ 458 │ │ │ │ │ raise TimeoutError() │ ... 1631: │ 221 │ │ except self._cancelled_exc_class: │ 1632: │ │ 1633: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 1634: │ │ args = () │ │ 1635: │ │ func = <bound method TestClient.wait_startup of │ │ 1636: │ │ <starlette.testclient.TestClient object at │ │ 1637: │ │ 0x7fab40ee2090>> │ │ 1638: │ │ future = <Future at 0x7fab40ee3f50 state=finished │ │ 1639: │ │ raised ValueError> │ │ ... 1643: │ │ scope = None │ │ 1644: │ │ self = <anyio._backends._asyncio.BlockingPortal │ │ 1645: │ │ object at 0x7fab4158ed20> │ │ 1646: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 1647: │ │ 1648: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 1649: │ ges/starlette/testclient.py:774 in wait_startup │ 1650: │ │ 1651: │ 771 │ │ │ "lifespan.startup.failed", │ 1652: │ 772 │ │ ) │ 1653: │ 773 │ │ if message["type"] == "lifespan.startup.failed": │ 1654: │ ❱ 774 │ │ │ await receive() │ 1655: │ 775 │ │ 1656: │ 776 │ async def wait_shutdown(self) -> None: │ 1657: │ 777 │ │ async def receive() -> typing.Any: │ 1658: │ │ 1659: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 1660: │ │ message = { │ │ 1661: │ │ │ 'type': 'lifespan.startup.failed', │ │ ... 1680: │ │ message = None │ │ 1681: │ │ self = <starlette.testclient.TestClient object at 0x7fab40ee2090> │ │ 1682: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 1683: │ │ 1684: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 1685: │ python3.12/concurrent/futures/_base.py:449 in result │ 1686: │ │ 1687: │ 446 │ │ │ │ if self._state in [CANCELLED, CANCELLED_AND_NOTIFI │ 1688: │ 447 │ │ │ │ │ raise CancelledError() │ ... 1724: │ 221 │ │ except self._cancelled_exc_class: │ 1725: │ │ 1726: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 1727: │ │ args = () │ │ 1728: │ │ func = <bound method TestClient.lifespan of │ │ 1729: │ │ <starlette.testclient.TestClient object at │ │ 1730: │ │ 0x7fab40ee2090>> │ │ 1731: │ │ future = <Future at 0x7fab40ec3d10 state=finished │ │ 1732: │ │ raised ValueError> │ │ ... 1839: │ │ waiting_senders=OrderedDict()), _closed=False), │ │ 1840: │ │ receive_stream=MemoryObjectReceiveStream(_state=MemoryObj… │ │ 1841: │ │ buffer=deque([]), open_send_channels=1, │ │ 1842: │ │ open_receive_channels=1, waiting_receivers=OrderedDict(), │ │ 1843: │ │ waiting_senders=OrderedDict()), _closed=False))> │ │ 1844: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 1845: │ │ 1846: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 1847: │ ges/starlette/middleware/errors.py:152 in __call__ │ ... 1867: │ │ scope = { │ │ 1868: │ │ │ 'type': 'lifespan', │ │ 1869: │ │ │ 'state': {}, │ │ 1870: │ │ │ 'app': <fastapi.applications.FastAPI object at │ │ 1871: │ │ 0x7fab42a2c170>, │ │ 1872: │ │ │ 'router': <fastapi.routing.APIRouter object at │ │ 1873: │ │ 0x7fab4f1c1e80> │ │ 1874: │ │ } │ │ 1875: │ │ self = <starlette.middleware.errors.ServerErrorMiddleware object │ │ ... 2097: │ ges/starlette/routing.py:693 in lifespan │ 2098: │ │ 2099: │ 690 │ │ app: typing.Any = scope.get("app") │ 2100: │ 691 │ │ await receive() │ 2101: │ 692 │ │ try: │ 2102: │ ❱ 693 │ │ │ async with self.lifespan_context(app) as maybe_state: │ 2103: │ 694 │ │ │ │ if maybe_state is not None: │ 2104: │ 695 │ │ │ │ │ if "state" not in scope: │ 2105: │ 696 │ │ │ │ │ │ raise RuntimeError('The server does not su │ ... 2141: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 2142: │ python3.12/contextlib.py:210 in __aenter__ │ 2143: │ │ 2144: │ 207 │ │ # they are only needed for recreation, which is not possib │ 2145: │ 208 │ │ del self.args, self.kwds, self.func │ 2146: │ 209 │ │ try: │ 2147: │ ❱ 210 │ │ │ return await anext(self.gen) │ 2148: │ 211 │ │ except StopAsyncIteration: │ 2149: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 2175: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 2176: │ python3.12/contextlib.py:210 in __aenter__ │ 2177: │ │ 2178: │ 207 │ │ # they are only needed for recreation, which is not possib │ 2179: │ 208 │ │ del self.args, self.kwds, self.func │ 2180: │ 209 │ │ try: │ 2181: │ ❱ 210 │ │ │ return await anext(self.gen) │ 2182: │ 211 │ │ except StopAsyncIteration: │ 2183: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 2209: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 2210: │ python3.12/contextlib.py:210 in __aenter__ │ 2211: │ │ 2212: │ 207 │ │ # they are only needed for recreation, which is not possib │ 2213: │ 208 │ │ del self.args, self.kwds, self.func │ 2214: │ 209 │ │ try: │ 2215: │ ❱ 210 │ │ │ return await anext(self.gen) │ 2216: │ 211 │ │ except StopAsyncIteration: │ 2217: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 2243: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 2244: │ python3.12/contextlib.py:210 in __aenter__ │ 2245: │ │ 2246: │ 207 │ │ # they are only needed for recreation, which is not possib │ 2247: │ 208 │ │ del self.args, self.kwds, self.func │ 2248: │ 209 │ │ try: │ 2249: │ ❱ 210 │ │ │ return await anext(self.gen) │ 2250: │ 211 │ │ except StopAsyncIteration: │ 2251: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 2277: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 2278: │ python3.12/contextlib.py:210 in __aenter__ │ 2279: │ │ 2280: │ 207 │ │ # they are only needed for recreation, which is not possib │ 2281: │ 208 │ │ del self.args, self.kwds, self.func │ 2282: │ 209 │ │ try: │ 2283: │ ❱ 210 │ │ │ return await anext(self.gen) │ 2284: │ 211 │ │ except StopAsyncIteration: │ 2285: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 2311: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 2312: │ python3.12/contextlib.py:210 in __aenter__ │ 2313: │ │ 2314: │ 207 │ │ # they are only needed for recreation, which is not possib │ 2315: │ 208 │ │ del self.args, self.kwds, self.func │ 2316: │ 209 │ │ try: │ 2317: │ ❱ 210 │ │ │ return await anext(self.gen) │ 2318: │ 211 │ │ except StopAsyncIteration: │ 2319: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 2345: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 2346: │ python3.12/contextlib.py:210 in __aenter__ │ 2347: │ │ 2348: │ 207 │ │ # they are only needed for recreation, which is not possib │ 2349: │ 208 │ │ del self.args, self.kwds, self.func │ 2350: │ 209 │ │ try: │ 2351: │ ❱ 210 │ │ │ return await anext(self.gen) │ 2352: │ 211 │ │ except StopAsyncIteration: │ 2353: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 2379: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 2380: │ python3.12/contextlib.py:210 in __aenter__ │ 2381: │ │ 2382: │ 207 │ │ # they are only needed for recreation, which is not possib │ 2383: │ 208 │ │ del self.args, self.kwds, self.func │ 2384: │ 209 │ │ try: │ 2385: │ ❱ 210 │ │ │ return await anext(self.gen) │ 2386: │ 211 │ │ except StopAsyncIteration: │ 2387: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 2413: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 2414: │ python3.12/contextlib.py:210 in __aenter__ │ 2415: │ │ 2416: │ 207 │ │ # they are only needed for recreation, which is not possib │ 2417: │ 208 │ │ del self.args, self.kwds, self.func │ 2418: │ 209 │ │ try: │ 2419: │ ❱ 210 │ │ │ return await anext(self.gen) │ 2420: │ 211 │ │ except StopAsyncIteration: │ 2421: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 2447: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 2448: │ python3.12/contextlib.py:210 in __aenter__ │ 2449: │ │ 2450: │ 207 │ │ # they are only needed for recreation, which is not possib │ 2451: │ 208 │ │ del self.args, self.kwds, self.func │ 2452: │ 209 │ │ try: │ 2453: │ ❱ 210 │ │ │ return await anext(self.gen) │ 2454: │ 211 │ │ except StopAsyncIteration: │ 2455: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 2481: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 2482: │ python3.12/contextlib.py:210 in __aenter__ │ 2483: │ │ 2484: │ 207 │ │ # they are only needed for recreation, which is not possib │ 2485: │ 208 │ │ del self.args, self.kwds, self.func │ 2486: │ 209 │ │ try: │ 2487: │ ❱ 210 │ │ │ return await anext(self.gen) │ 2488: │ 211 │ │ except StopAsyncIteration: │ 2489: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 2552: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 2553: │ │ 2554: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 2555: │ ges/asyncpg/pool.py:361 in __init__ │ 2556: │ │ 2557: │ 358 │ │ │ │ 'min_size is expected to be greater or equal to z │ 2558: │ 359 │ │ │ 2559: │ 360 │ │ if min_size > max_size: │ 2560: │ ❱ 361 │ │ │ raise ValueError('min_size is greater than max_size') │ 2561: │ 362 │ │ │ 2562: │ 363 │ │ if max_queries <= 0: │ 2563: │ 364 │ │ │ raise ValueError('max_queries is expected to be great │ ... 2577: │ │ max_size = 4 │ │ 2578: │ │ min_size = 10 │ │ 2579: │ │ reset = None │ │ 2580: │ │ self = <asyncpg.pool.Pool object at │ │ 2581: │ │ 0x7fab40e55f00> │ │ 2582: │ │ setup = None │ │ 2583: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 2584: ╰──────────────────────────────────────────────────────────────────────────╯ 2585: ValueError: min_size is greater than max_size ... 2662: │ │ │ } │ │ 2663: │ │ ) │ │ 2664: │ │ self = TestArgumentResolver( │ │ 2665: │ │ │ test=Test( │ │ 2666: │ │ │ │ fn=<function _ at 0x7fab41046980>, │ │ 2667: │ │ │ │ module_name='test_agent_routes', │ │ 2668: │ │ │ │ id='a4d0131e9e4e4176a0e1fda69aa5b577', │ │ 2669: │ │ │ │ marker=None, │ │ 2670: │ │ │ │ description='route: unauthorized should fail', │ │ ... 2789: │ │ resolved_args = {} │ │ 2790: │ │ self = TestArgumentResolver( │ │ 2791: │ │ │ test=Test( │ │ 2792: │ │ │ │ fn=<function _ at 0x7fab41046980>, │ │ 2793: │ │ │ │ module_name='test_agent_routes', │ │ 2794: │ │ │ │ id='a4d0131e9e4e4176a0e1fda69aa5b577', │ │ 2795: │ │ │ │ marker=None, │ │ 2796: │ │ │ │ description='route: unauthorized should │ │ 2797: │ │ fail', │ │ ... 2822: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 2823: │ │ 2824: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 2825: │ ges/ward/testing.py:637 in _resolve_single_arg │ 2826: │ │ 2827: │ 634 │ │ │ else: │ 2828: │ 635 │ │ │ │ fixture.resolved_val = arg(**args_to_inject) │ 2829: │ 636 │ │ except (Exception, SystemExit) as e: │ 2830: │ ❱ 637 │ │ │ raise FixtureError(f"Unable to resolve fixture '{fixtu │ ... 2943: │ │ name = '_dsn' │ │ 2944: │ │ self = TestArgumentResolver( │ │ 2945: │ │ │ test=Test( │ │ 2946: │ │ │ │ fn=<function _ at 0x7fab41046980>, │ │ 2947: │ │ │ │ module_name='test_agent_routes', │ │ 2948: │ │ │ │ id='a4d0131e9e4e4176a0e1fda69aa5b577', │ │ 2949: │ │ │ │ marker=None, │ │ 2950: │ │ │ │ description='route: unauthorized should │ │ 2951: │ │ fail', │ │ ... 2970: │ │ │ │ timer=<ward._testing._Timer object at │ │ 2971: │ │ 0x7fab40f1caa0>, │ │ 2972: │ │ │ │ tags=[] │ │ 2973: │ │ │ ), │ │ 2974: │ │ │ iteration=0 │ │ 2975: │ │ ) │ │ 2976: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 2977: ╰──────────────────────────────────────────────────────────────────────────╯ 2978: FixtureError: Unable to resolve fixture 'client' 2979: ───────────────────────────── route: create agent ────────────────────────────── 2980: Failed at tests/test_agent_routes.py ... 3227: │ │ self = <anyio._backends._asyncio.BlockingPortal object at │ │ 3228: │ │ 0x7fab40ec0260> │ │ 3229: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 3230: │ │ 3231: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 3232: │ python3.12/concurrent/futures/_base.py:456 in result │ 3233: │ │ 3234: │ 453 │ │ │ │ if self._state in [CANCELLED, CANCELLED_AND_NOTIFI │ 3235: │ 454 │ │ │ │ │ raise CancelledError() │ 3236: │ 455 │ │ │ │ elif self._state == FINISHED: │ 3237: │ ❱ 456 │ │ │ │ │ return self.__get_result() │ 3238: │ 457 │ │ │ │ else: │ 3239: │ 458 │ │ │ │ │ raise TimeoutError() │ ... 3271: │ 221 │ │ except self._cancelled_exc_class: │ 3272: │ │ 3273: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 3274: │ │ args = () │ │ 3275: │ │ func = <bound method TestClient.wait_startup of │ │ 3276: │ │ <starlette.testclient.TestClient object at │ │ 3277: │ │ 0x7fab40ec3920>> │ │ 3278: │ │ future = <Future at 0x7fab40ec09e0 state=finished │ │ 3279: │ │ raised ValueError> │ │ ... 3283: │ │ scope = None │ │ 3284: │ │ self = <anyio._backends._asyncio.BlockingPortal │ │ 3285: │ │ object at 0x7fab40ec0260> │ │ 3286: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 3287: │ │ 3288: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 3289: │ ges/starlette/testclient.py:774 in wait_startup │ 3290: │ │ 3291: │ 771 │ │ │ "lifespan.startup.failed", │ 3292: │ 772 │ │ ) │ 3293: │ 773 │ │ if message["type"] == "lifespan.startup.failed": │ 3294: │ ❱ 774 │ │ │ await receive() │ 3295: │ 775 │ │ 3296: │ 776 │ async def wait_shutdown(self) -> None: │ 3297: │ 777 │ │ async def receive() -> typing.Any: │ 3298: │ │ 3299: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 3300: │ │ message = { │ │ 3301: │ │ │ 'type': 'lifespan.startup.failed', │ │ ... 3320: │ │ message = None │ │ 3321: │ │ self = <starlette.testclient.TestClient object at 0x7fab40ec3920> │ │ 3322: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 3323: │ │ 3324: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 3325: │ python3.12/concurrent/futures/_base.py:449 in result │ 3326: │ │ 3327: │ 446 │ │ │ │ if self._state in [CANCELLED, CANCELLED_AND_NOTIFI │ 3328: │ 447 │ │ │ │ │ raise CancelledError() │ ... 3364: │ 221 │ │ except self._cancelled_exc_class: │ 3365: │ │ 3366: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 3367: │ │ args = () │ │ 3368: │ │ func = <bound method TestClient.lifespan of │ │ 3369: │ │ <starlette.testclient.TestClient object at │ │ 3370: │ │ 0x7fab40ec3920>> │ │ 3371: │ │ future = <Future at 0x7fab40ec0a10 state=finished │ │ 3372: │ │ raised ValueError> │ │ ... 3479: │ │ waiting_senders=OrderedDict()), _closed=False), │ │ 3480: │ │ receive_stream=MemoryObjectReceiveStream(_state=MemoryObj… │ │ 3481: │ │ buffer=deque([]), open_send_channels=1, │ │ 3482: │ │ open_receive_channels=1, waiting_receivers=OrderedDict(), │ │ 3483: │ │ waiting_senders=OrderedDict()), _closed=False))> │ │ 3484: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 3485: │ │ 3486: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 3487: │ ges/starlette/middleware/errors.py:152 in __call__ │ ... 3507: │ │ scope = { │ │ 3508: │ │ │ 'type': 'lifespan', │ │ 3509: │ │ │ 'state': {}, │ │ 3510: │ │ │ 'app': <fastapi.applications.FastAPI object at │ │ 3511: │ │ 0x7fab42a2c170>, │ │ 3512: │ │ │ 'router': <fastapi.routing.APIRouter object at │ │ 3513: │ │ 0x7fab4f1c1e80> │ │ 3514: │ │ } │ │ 3515: │ │ self = <starlette.middleware.errors.ServerErrorMiddleware object │ │ ... 3737: │ ges/starlette/routing.py:693 in lifespan │ 3738: │ │ 3739: │ 690 │ │ app: typing.Any = scope.get("app") │ 3740: │ 691 │ │ await receive() │ 3741: │ 692 │ │ try: │ 3742: │ ❱ 693 │ │ │ async with self.lifespan_context(app) as maybe_state: │ 3743: │ 694 │ │ │ │ if maybe_state is not None: │ 3744: │ 695 │ │ │ │ │ if "state" not in scope: │ 3745: │ 696 │ │ │ │ │ │ raise RuntimeError('The server does not su │ ... 3781: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 3782: │ python3.12/contextlib.py:210 in __aenter__ │ 3783: │ │ 3784: │ 207 │ │ # they are only needed for recreation, which is not possib │ 3785: │ 208 │ │ del self.args, self.kwds, self.func │ 3786: │ 209 │ │ try: │ 3787: │ ❱ 210 │ │ │ return await anext(self.gen) │ 3788: │ 211 │ │ except StopAsyncIteration: │ 3789: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 3815: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 3816: │ python3.12/contextlib.py:210 in __aenter__ │ 3817: │ │ 3818: │ 207 │ │ # they are only needed for recreation, which is not possib │ 3819: │ 208 │ │ del self.args, self.kwds, self.func │ 3820: │ 209 │ │ try: │ 3821: │ ❱ 210 │ │ │ return await anext(self.gen) │ 3822: │ 211 │ │ except StopAsyncIteration: │ 3823: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 3849: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 3850: │ python3.12/contextlib.py:210 in __aenter__ │ 3851: │ │ 3852: │ 207 │ │ # they are only needed for recreation, which is not possib │ 3853: │ 208 │ │ del self.args, self.kwds, self.func │ 3854: │ 209 │ │ try: │ 3855: │ ❱ 210 │ │ │ return await anext(self.gen) │ 3856: │ 211 │ │ except StopAsyncIteration: │ 3857: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 3883: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 3884: │ python3.12/contextlib.py:210 in __aenter__ │ 3885: │ │ 3886: │ 207 │ │ # they are only needed for recreation, which is not possib │ 3887: │ 208 │ │ del self.args, self.kwds, self.func │ 3888: │ 209 │ │ try: │ 3889: │ ❱ 210 │ │ │ return await anext(self.gen) │ 3890: │ 211 │ │ except StopAsyncIteration: │ 3891: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 3917: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 3918: │ python3.12/contextlib.py:210 in __aenter__ │ 3919: │ │ 3920: │ 207 │ │ # they are only needed for recreation, which is not possib │ 3921: │ 208 │ │ del self.args, self.kwds, self.func │ 3922: │ 209 │ │ try: │ 3923: │ ❱ 210 │ │ │ return await anext(self.gen) │ 3924: │ 211 │ │ except StopAsyncIteration: │ 3925: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 3951: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 3952: │ python3.12/contextlib.py:210 in __aenter__ │ 3953: │ │ 3954: │ 207 │ │ # they are only needed for recreation, which is not possib │ 3955: │ 208 │ │ del self.args, self.kwds, self.func │ 3956: │ 209 │ │ try: │ 3957: │ ❱ 210 │ │ │ return await anext(self.gen) │ 3958: │ 211 │ │ except StopAsyncIteration: │ 3959: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 3985: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 3986: │ python3.12/contextlib.py:210 in __aenter__ │ 3987: │ │ 3988: │ 207 │ │ # they are only needed for recreation, which is not possib │ 3989: │ 208 │ │ del self.args, self.kwds, self.func │ 3990: │ 209 │ │ try: │ 3991: │ ❱ 210 │ │ │ return await anext(self.gen) │ 3992: │ 211 │ │ except StopAsyncIteration: │ 3993: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 4019: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 4020: │ python3.12/contextlib.py:210 in __aenter__ │ 4021: │ │ 4022: │ 207 │ │ # they are only needed for recreation, which is not possib │ 4023: │ 208 │ │ del self.args, self.kwds, self.func │ 4024: │ 209 │ │ try: │ 4025: │ ❱ 210 │ │ │ return await anext(self.gen) │ 4026: │ 211 │ │ except StopAsyncIteration: │ 4027: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 4053: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 4054: │ python3.12/contextlib.py:210 in __aenter__ │ 4055: │ │ 4056: │ 207 │ │ # they are only needed for recreation, which is not possib │ 4057: │ 208 │ │ del self.args, self.kwds, self.func │ 4058: │ 209 │ │ try: │ 4059: │ ❱ 210 │ │ │ return await anext(self.gen) │ 4060: │ 211 │ │ except StopAsyncIteration: │ 4061: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 4087: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 4088: │ python3.12/contextlib.py:210 in __aenter__ │ 4089: │ │ 4090: │ 207 │ │ # they are only needed for recreation, which is not possib │ 4091: │ 208 │ │ del self.args, self.kwds, self.func │ 4092: │ 209 │ │ try: │ 4093: │ ❱ 210 │ │ │ return await anext(self.gen) │ 4094: │ 211 │ │ except StopAsyncIteration: │ 4095: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 4121: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 4122: │ python3.12/contextlib.py:210 in __aenter__ │ 4123: │ │ 4124: │ 207 │ │ # they are only needed for recreation, which is not possib │ 4125: │ 208 │ │ del self.args, self.kwds, self.func │ 4126: │ 209 │ │ try: │ 4127: │ ❱ 210 │ │ │ return await anext(self.gen) │ 4128: │ 211 │ │ except StopAsyncIteration: │ 4129: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 4192: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 4193: │ │ 4194: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 4195: │ ges/asyncpg/pool.py:361 in __init__ │ 4196: │ │ 4197: │ 358 │ │ │ │ 'min_size is expected to be greater or equal to z │ 4198: │ 359 │ │ │ 4199: │ 360 │ │ if min_size > max_size: │ 4200: │ ❱ 361 │ │ │ raise ValueError('min_size is greater than max_size') │ 4201: │ 362 │ │ │ 4202: │ 363 │ │ if max_queries <= 0: │ 4203: │ 364 │ │ │ raise ValueError('max_queries is expected to be great │ ... 4217: │ │ max_size = 4 │ │ 4218: │ │ min_size = 10 │ │ 4219: │ │ reset = None │ │ 4220: │ │ self = <asyncpg.pool.Pool object at │ │ 4221: │ │ 0x7fab40ed9e40> │ │ 4222: │ │ setup = None │ │ 4223: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 4224: ╰──────────────────────────────────────────────────────────────────────────╯ 4225: ValueError: min_size is greater than max_size ... 4603: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 4604: │ │ 4605: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 4606: │ ges/ward/testing.py:637 in _resolve_single_arg │ 4607: │ │ 4608: │ 634 │ │ │ else: │ 4609: │ 635 │ │ │ │ fixture.resolved_val = arg(**args_to_inject) │ 4610: │ 636 │ │ except (Exception, SystemExit) as e: │ 4611: │ ❱ 637 │ │ │ raise FixtureError(f"Unable to resolve fixture '{fixtu │ ... 4750: │ │ │ │ timer=<ward._testing._Timer object at │ │ 4751: │ │ 0x7fab40ee33e0>, │ │ 4752: │ │ │ │ tags=[] │ │ 4753: │ │ │ ), │ │ 4754: │ │ │ iteration=0 │ │ 4755: │ │ ) │ │ 4756: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 4757: ╰──────────────────────────────────────────────────────────────────────────╯ 4758: FixtureError: Unable to resolve fixture 'client' 4759: ──────────────────── route: create agent with instructions ───────────────────── 4760: Failed at tests/test_agent_routes.py ... 5008: │ │ self = <anyio._backends._asyncio.BlockingPortal object at │ │ 5009: │ │ 0x7fab40ea7d10> │ │ 5010: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 5011: │ │ 5012: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 5013: │ python3.12/concurrent/futures/_base.py:456 in result │ 5014: │ │ 5015: │ 453 │ │ │ │ if self._state in [CANCELLED, CANCELLED_AND_NOTIFI │ 5016: │ 454 │ │ │ │ │ raise CancelledError() │ 5017: │ 455 │ │ │ │ elif self._state == FINISHED: │ 5018: │ ❱ 456 │ │ │ │ │ return self.__get_result() │ 5019: │ 457 │ │ │ │ else: │ 5020: │ 458 │ │ │ │ │ raise TimeoutError() │ ... 5052: │ 221 │ │ except self._cancelled_exc_class: │ 5053: │ │ 5054: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 5055: │ │ args = () │ │ 5056: │ │ func = <bound method TestClient.wait_startup of │ │ 5057: │ │ <starlette.testclient.TestClient object at │ │ 5058: │ │ 0x7fab40ec0c80>> │ │ 5059: │ │ future = <Future at 0x7fab40ea74a0 state=finished │ │ 5060: │ │ raised ValueError> │ │ ... 5064: │ │ scope = None │ │ 5065: │ │ self = <anyio._backends._asyncio.BlockingPortal │ │ 5066: │ │ object at 0x7fab40ea7d10> │ │ 5067: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 5068: │ │ 5069: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 5070: │ ges/starlette/testclient.py:774 in wait_startup │ 5071: │ │ 5072: │ 771 │ │ │ "lifespan.startup.failed", │ 5073: │ 772 │ │ ) │ 5074: │ 773 │ │ if message["type"] == "lifespan.startup.failed": │ 5075: │ ❱ 774 │ │ │ await receive() │ 5076: │ 775 │ │ 5077: │ 776 │ async def wait_shutdown(self) -> None: │ 5078: │ 777 │ │ async def receive() -> typing.Any: │ 5079: │ │ 5080: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 5081: │ │ message = { │ │ 5082: │ │ │ 'type': 'lifespan.startup.failed', │ │ ... 5101: │ │ message = None │ │ 5102: │ │ self = <starlette.testclient.TestClient object at 0x7fab40ec0c80> │ │ 5103: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 5104: │ │ 5105: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 5106: │ python3.12/concurrent/futures/_base.py:449 in result │ 5107: │ │ 5108: │ 446 │ │ │ │ if self._state in [CANCELLED, CANCELLED_AND_NOTIFI │ 5109: │ 447 │ │ │ │ │ raise CancelledError() │ ... 5145: │ 221 │ │ except self._cancelled_exc_class: │ 5146: │ │ 5147: │ ╭─────────────────────────────── locals ───────────────────────────────╮ │ 5148: │ │ args = () │ │ 5149: │ │ func = <bound method TestClient.lifespan of │ │ 5150: │ │ <starlette.testclient.TestClient object at │ │ 5151: │ │ 0x7fab40ec0c80>> │ │ 5152: │ │ future = <Future at 0x7fab40ea7320 state=finished │ │ 5153: │ │ raised ValueError> │ │ ... 5260: │ │ waiting_senders=OrderedDict()), _closed=False), │ │ 5261: │ │ receive_stream=MemoryObjectReceiveStream(_state=MemoryObj… │ │ 5262: │ │ buffer=deque([]), open_send_channels=1, │ │ 5263: │ │ open_receive_channels=1, waiting_receivers=OrderedDict(), │ │ 5264: │ │ waiting_senders=OrderedDict()), _closed=False))> │ │ 5265: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 5266: │ │ 5267: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 5268: │ ges/starlette/middleware/errors.py:152 in __call__ │ ... 5288: │ │ scope = { │ │ 5289: │ │ │ 'type': 'lifespan', │ │ 5290: │ │ │ 'state': {}, │ │ 5291: │ │ │ 'app': <fastapi.applications.FastAPI object at │ │ 5292: │ │ 0x7fab42a2c170>, │ │ 5293: │ │ │ 'router': <fastapi.routing.APIRouter object at │ │ 5294: │ │ 0x7fab4f1c1e80> │ │ 5295: │ │ } │ │ 5296: │ │ self = <starlette.middleware.errors.ServerErrorMiddleware object │ │ ... 5518: │ ges/starlette/routing.py:693 in lifespan │ 5519: │ │ 5520: │ 690 │ │ app: typing.Any = scope.get("app") │ 5521: │ 691 │ │ await receive() │ 5522: │ 692 │ │ try: │ 5523: │ ❱ 693 │ │ │ async with self.lifespan_context(app) as maybe_state: │ 5524: │ 694 │ │ │ │ if maybe_state is not None: │ 5525: │ 695 │ │ │ │ │ if "state" not in scope: │ 5526: │ 696 │ │ │ │ │ │ raise RuntimeError('The server does not su │ ... 5562: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 5563: │ python3.12/contextlib.py:210 in __aenter__ │ 5564: │ │ 5565: │ 207 │ │ # they are only needed for recreation, which is not possib │ 5566: │ 208 │ │ del self.args, self.kwds, self.func │ 5567: │ 209 │ │ try: │ 5568: │ ❱ 210 │ │ │ return await anext(self.gen) │ 5569: │ 211 │ │ except StopAsyncIteration: │ 5570: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 5596: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 5597: │ python3.12/contextlib.py:210 in __aenter__ │ 5598: │ │ 5599: │ 207 │ │ # they are only needed for recreation, which is not possib │ 5600: │ 208 │ │ del self.args, self.kwds, self.func │ 5601: │ 209 │ │ try: │ 5602: │ ❱ 210 │ │ │ return await anext(self.gen) │ 5603: │ 211 │ │ except StopAsyncIteration: │ 5604: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 5630: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 5631: │ python3.12/contextlib.py:210 in __aenter__ │ 5632: │ │ 5633: │ 207 │ │ # they are only needed for recreation, which is not possib │ 5634: │ 208 │ │ del self.args, self.kwds, self.func │ 5635: │ 209 │ │ try: │ 5636: │ ❱ 210 │ │ │ return await anext(self.gen) │ 5637: │ 211 │ │ except StopAsyncIteration: │ 5638: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 5664: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 5665: │ python3.12/contextlib.py:210 in __aenter__ │ 5666: │ │ 5667: │ 207 │ │ # they are only needed for recreation, which is not possib │ 5668: │ 208 │ │ del self.args, self.kwds, self.func │ 5669: │ 209 │ │ try: │ 5670: │ ❱ 210 │ │ │ return await anext(self.gen) │ 5671: │ 211 │ │ except StopAsyncIteration: │ 5672: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 5698: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 5699: │ python3.12/contextlib.py:210 in __aenter__ │ 5700: │ │ 5701: │ 207 │ │ # they are only needed for recreation, which is not possib │ 5702: │ 208 │ │ del self.args, self.kwds, self.func │ 5703: │ 209 │ │ try: │ 5704: │ ❱ 210 │ │ │ return await anext(self.gen) │ 5705: │ 211 │ │ except StopAsyncIteration: │ 5706: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 5732: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 5733: │ python3.12/contextlib.py:210 in __aenter__ │ 5734: │ │ 5735: │ 207 │ │ # they are only needed for recreation, which is not possib │ 5736: │ 208 │ │ del self.args, self.kwds, self.func │ 5737: │ 209 │ │ try: │ 5738: │ ❱ 210 │ │ │ return await anext(self.gen) │ 5739: │ 211 │ │ except StopAsyncIteration: │ 5740: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 5766: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 5767: │ python3.12/contextlib.py:210 in __aenter__ │ 5768: │ │ 5769: │ 207 │ │ # they are only needed for recreation, which is not possib │ 5770: │ 208 │ │ del self.args, self.kwds, self.func │ 5771: │ 209 │ │ try: │ 5772: │ ❱ 210 │ │ │ return await anext(self.gen) │ 5773: │ 211 │ │ except StopAsyncIteration: │ 5774: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 5800: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 5801: │ python3.12/contextlib.py:210 in __aenter__ │ 5802: │ │ 5803: │ 207 │ │ # they are only needed for recreation, which is not possib │ 5804: │ 208 │ │ del self.args, self.kwds, self.func │ 5805: │ 209 │ │ try: │ 5806: │ ❱ 210 │ │ │ return await anext(self.gen) │ 5807: │ 211 │ │ except StopAsyncIteration: │ 5808: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 5834: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 5835: │ python3.12/contextlib.py:210 in __aenter__ │ 5836: │ │ 5837: │ 207 │ │ # they are only needed for recreation, which is not possib │ 5838: │ 208 │ │ del self.args, self.kwds, self.func │ 5839: │ 209 │ │ try: │ 5840: │ ❱ 210 │ │ │ return await anext(self.gen) │ 5841: │ 211 │ │ except StopAsyncIteration: │ 5842: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 5868: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 5869: │ python3.12/contextlib.py:210 in __aenter__ │ 5870: │ │ 5871: │ 207 │ │ # they are only needed for recreation, which is not possib │ 5872: │ 208 │ │ del self.args, self.kwds, self.func │ 5873: │ 209 │ │ try: │ 5874: │ ❱ 210 │ │ │ return await anext(self.gen) │ 5875: │ 211 │ │ except StopAsyncIteration: │ 5876: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 5902: │ /home/runner/.local/share/uv/python/cpython-3.12.8-linux-x86_64-gnu/lib/ │ 5903: │ python3.12/contextlib.py:210 in __aenter__ │ 5904: │ │ 5905: │ 207 │ │ # they are only needed for recreation, which is not possib │ 5906: │ 208 │ │ del self.args, self.kwds, self.func │ 5907: │ 209 │ │ try: │ 5908: │ ❱ 210 │ │ │ return await anext(self.gen) │ 5909: │ 211 │ │ except StopAsyncIteration: │ 5910: │ 212 │ │ │ raise RuntimeError("generator didn't yield") from None │ ... 5973: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 5974: │ │ 5975: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 5976: │ ges/asyncpg/pool.py:361 in __init__ │ 5977: │ │ 5978: │ 358 │ │ │ │ 'min_size is expected to be greater or equal to z │ 5979: │ 359 │ │ │ 5980: │ 360 │ │ if min_size > max_size: │ 5981: │ ❱ 361 │ │ │ raise ValueError('min_size is greater than max_size') │ 5982: │ 362 │ │ │ 5983: │ 363 │ │ if max_queries <= 0: │ 5984: │ 364 │ │ │ raise ValueError('max_queries is expected to be great │ ... 5998: │ │ max_size = 4 │ │ 5999: │ │ min_size = 10 │ │ 6000: │ │ reset = None │ │ 6001: │ │ self = <asyncpg.pool.Pool object at │ │ 6002: │ │ 0x7fab40ed9540> │ │ 6003: │ │ setup = None │ │ 6004: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 6005: ╰──────────────────────────────────────────────────────────────────────────╯ 6006: ValueError: min_size is greater than max_size ... 6386: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 6387: │ │ 6388: │ /home/runner/work/julep/julep/agents-api/.venv/lib/python3.12/site-packa │ 6389: │ ges/ward/testing.py:637 in _resolve_single_arg │ 6390: │ │ 6391: │ 634 │ │ │ else: │ 6392: │ 635 │ │ │ │ fixture.resolved_val = arg(**args_to_inject) │ 6393: │ 636 │ │ except (Exception, SystemExit) as e: │ 6394: │ ❱ 637 │ │ │ raise FixtureError(f"Unable to resolve fixture '{fixtu │ ... 6534: │ │ │ │ timer=<ward._testing._Timer object at │ │ 6535: │ │ 0x7fab40ee13d0>, │ │ 6536: │ │ │ │ tags=[] │ │ 6537: │ │ │ ), │ │ 6538: │ │ │ iteration=0 │ │ 6539: │ │ ) │ │ 6540: │ ╰──────────────────────────────────────────────────────────────────────╯ │ 6541: ╰──────────────────────────────────────────────────────────────────────────╯ 6542: FixtureError: Unable to resolve fixture 'client' 6543: ──────────────────────────────────────────────────────────────────────────────── 6544: ╭──────────── Results ─────────────╮ 6545: │ 12 Tests Encountered │ 6546: │ 9 Passes (75.0%) │ 6547: │ 3 Failures (25.0%) │ 6548: ╰──────────────────────────────────╯ 6549: ─────────────────────────── FAILED in 51.59 seconds ──────────────────────────── 6550: ##[error]Process completed with exit code 1.

---

✨ CI feedback usage guide:

---

The CI feedback tool (/checks) automatically triggers when a PR has a failed check.
The tool analyzes the failed checks and provides several feedbacks:

• Failed stage
• Failed test name
• Failure summary
• Relevant error logs

In addition to being automatically triggered, the tool can also be invoked manually by commenting on a PR:

/checks "https://github.com/{repo_name}/actions/runs/{run_number}/job/{job_number}"

where {repo_name} is the name of the repository, {run_number} is the run number of the failed check, and `{job...

[qodo-merge-pro-for-open-source]

PR Reviewer Guide 🔍

Here are some key observations to aid the review process:

⏱️ Estimated effort to review: 3 🔵🔵🔵⚪⚪

🧪 PR contains tests

🔒 No security concerns identified

⚡ Recommended focus areas for review Performance The extract_keywords function creates multiple intermediate lists and sets which could be optimized to reduce memory usage, especially for large documents. Consider combining operations to reduce allocations. def extract_keywords( doc: Doc, top_n: int = 25, clean: bool = True, split_chunks: bool = False ) -> list[str]: """Optimized keyword extraction with minimal behavior change.""" excluded_labels = { "DATE", # Absolute or relative dates or periods. "TIME", # Times smaller than a day. "PERCENT", # Percentage, including ”%“. "MONEY", # Monetary values, including unit. "QUANTITY", # Measurements, as of weight or distance. "ORDINAL", # “first”, “second”, etc. "CARDINAL", # Numerals that do not fall under another type. # "PERSON", # People, including fictional. # "NORP", # Nationalities or religious or political groups. # "FAC", # Buildings, airports, highways, bridges, etc. # "ORG", # Companies, agencies, institutions, etc. # "GPE", # Countries, cities, states. # "LOC", # Non-GPE locations, mountain ranges, bodies of water. # "PRODUCT", # Objects, vehicles, foods, etc. (Not services.) # "EVENT", # Named hurricanes, battles, wars, sports events, etc. # "WORK_OF_ART", # Titles of books, songs, etc. # "LAW", # Named documents made into laws. # "LANGUAGE", # Any named language. } # Extract and filter spans in a single pass ent_spans = [ent for ent in doc.ents if ent.label_ not in excluded_labels] # Add more comprehensive stopword filtering for noun chunks chunk_spans = [ chunk for chunk in doc.noun_chunks if not chunk.root.is_stop and not all(token.is_stop for token in chunk) ] all_spans = filter_spans(ent_spans + chunk_spans) # Process spans efficiently and filter out spans that are entirely stopwords keywords = [] ent_keywords = [] seen_texts = set() # Convert ent_spans to set for faster lookup ent_spans_set = set(ent_spans) for span in all_spans: # Skip if all tokens in span are stopwords if all(token.is_stop for token in span): continue text = span.text.strip() lower_text = text.lower() # Skip empty or seen texts if not text or lower_text in seen_texts: continue seen_texts.add(lower_text) ent_keywords.append(text) if span in ent_spans_set else keywords.append(text) # Normalize keywords by replacing multiple spaces with single space and stripping normalized_ent_keywords = [WHITESPACE_RE.sub(" ", kw).strip() for kw in ent_keywords] normalized_keywords = [WHITESPACE_RE.sub(" ", kw).strip() for kw in keywords] if split_chunks: normalized_keywords = [word for kw in normalized_keywords for word in kw.split()] # Count frequencies efficiently ent_freq = Counter(normalized_ent_keywords) freq = Counter(normalized_keywords) top_keywords = [kw for kw, _ in ent_freq.most_common(top_n)] remaining_slots = max(0, top_n - len(top_keywords)) top_keywords += [kw for kw, _ in freq.most_common(remaining_slots)] if clean: return [clean_keyword(kw) for kw in top_keywords] return top_keywords Edge Case The clean_keyword function may not properly handle all Unicode characters and special punctuation marks. Consider adding more comprehensive Unicode character handling. def clean_keyword(kw: str) -> str: """Cache cleaned keywords for reuse.""" # First remove non-alphanumeric chars (except whitespace, hyphens, underscores) cleaned = NON_ALPHANUM_RE.sub("", kw).strip() # Replace lone hyphens with spaces cleaned = LONE_HYPHEN_RE.sub(" ", cleaned) # Clean up any resulting multiple spaces return WHITESPACE_RE.sub(" ", cleaned).strip()

[qodo-merge-pro-for-open-source]

PR Code Suggestions ✨

Explore these optional code suggestions:

Category	Suggestion	Score
General	Add input validation to prevent processing of invalid or empty text inputs The text_to_tsvector_query function is missing error handling for empty or invalid input text. Add input validation to prevent potential issues with malformed queries. agents-api/agents_api/common/nlp.py [123-125] def text_to_tsvector_query( paragraph: str, top_n: int = 25, min_keywords: int = 1, split_chunks: bool = False ) -> str: + if not paragraph or not isinstance(paragraph, str): + return "" + if not paragraph.strip(): + return "" Apply this suggestion Suggestion importance[1-10]: 7 Why: The suggestion adds important input validation to prevent potential errors from invalid inputs, which could improve the function's robustness and reliability in production environments.	7

[ellipsis-dev]

👍 Looks good to me! Reviewed everything up to 2c25490 in 1 minute and 14 seconds

More details

• Looked at 639 lines of code in 5 files
• Skipped 0 files when reviewing.
• Skipped posting 2 drafted comments based on config settings.

1. agents-api/agents_api/common/nlp.py:1

• Draft comment:
  The removal of the KeywordMatcher class and related functions might impact performance if keyword matching was a critical feature. Ensure this change aligns with the intended functionality.
• Reason this comment was not posted:
  Confidence changes required: 50%
  The removal of the KeywordMatcher class and related functions seems intentional, but it might affect performance if keyword matching was a critical feature. The PR description doesn't mention why it was removed, so it's worth noting.

2. agents-api/agents_api/common/nlp.py:162

• Draft comment:
  The batch_text_to_tsvector_queries function is commented out. If it's not needed, consider removing it to keep the code clean. If it might be needed later, add a comment explaining why it's commented out.
• Reason this comment was not posted:
  Confidence changes required: 33%
  The batch_text_to_tsvector_queries function is commented out. If it's not needed, it should be removed to keep the code clean. If it might be needed later, consider adding a comment explaining why it's commented out.

Workflow ID: wflow_YkDiVPXGOGQxzNTW

---

You can customize Ellipsis with 👍 / 👎 feedback, review rules, user-specific overrides, quiet mode, and more.

[ellipsis-dev]

👍 Looks good to me! Incremental review on 9eb018f in 44 seconds

More details

• Looked at 25 lines of code in 1 files
• Skipped 0 files when reviewing.
• Skipped posting 1 drafted comments based on config settings.

1. agents-api/agents_api/common/nlp.py:45

• Draft comment:
  The 'clean' parameter was removed from the 'extract_keywords' function, but the docstring was not updated to reflect this change. Consider updating the docstring to avoid confusion.
• Reason this comment was not posted:
  Comment looked like it was already resolved.

Workflow ID: wflow_VpSu58JemWgQgX69

---

You can customize Ellipsis with 👍 / 👎 feedback, review rules, user-specific overrides, quiet mode, and more.

[ellipsis-dev]

👍 Looks good to me! Incremental review on 8fe87cb in 38 seconds

More details

• Looked at 84 lines of code in 4 files
• Skipped 0 files when reviewing.
• Skipped posting 2 drafted comments based on config settings.

1. agents-api/agents_api/queries/docs/search_docs_by_text.py:65

• Draft comment:
  The split_chunks=True parameter is consistent with the updated default behavior in text_to_tsvector_query. Ensure this aligns with the intended query processing logic.
• Reason this comment was not posted:
  Confidence changes required: 50%
  The use of split_chunks=True in the text_to_tsvector_query function calls in search_docs_by_text.py and search_docs_hybrid.py is consistent with the changes made in the nlp.py file, where the default value for split_chunks was changed to True. This ensures that the function behaves as intended with the new default behavior.

2. agents-api/agents_api/queries/docs/search_docs_hybrid.py:86

• Draft comment:
  The split_chunks=True parameter is consistent with the updated default behavior in text_to_tsvector_query. Ensure this aligns with the intended query processing logic.
• Reason this comment was not posted:
  Confidence changes required: 50%
  The use of split_chunks=True in the text_to_tsvector_query function calls in search_docs_by_text.py and search_docs_hybrid.py is consistent with the changes made in the nlp.py file, where the default value for split_chunks was changed to True. This ensures that the function behaves as intended with the new default behavior.

Workflow ID: wflow_onSRXNoVAqdcgn4e

---

You can customize Ellipsis with 👍 / 👎 feedback, review rules, user-specific overrides, quiet mode, and more.

[ellipsis-dev]

👍 Looks good to me! Incremental review on fcd2ad3 in 17 seconds

More details

• Looked at 35 lines of code in 1 files
• Skipped 0 files when reviewing.
• Skipped posting 0 drafted comments based on config settings.

Workflow ID: wflow_kiCeiYaQ6CzTnLy5

---

You can customize Ellipsis with 👍 / 👎 feedback, review rules, user-specific overrides, quiet mode, and more.