From fece441847ba0178c5b6d5888ac1154b30360529 Mon Sep 17 00:00:00 2001 From: Dmitry Paramonov Date: Fri, 27 Dec 2024 12:29:27 +0300 Subject: [PATCH] chore: Unskip tests --- agents-api/tests/test_docs_routes.py | 13 ++----------- agents-api/tests/test_execution_workflow.py | 18 ------------------ 2 files changed, 2 insertions(+), 29 deletions(-) diff --git a/agents-api/tests/test_docs_routes.py b/agents-api/tests/test_docs_routes.py index c15f9b393..579e1daea 100644 --- a/agents-api/tests/test_docs_routes.py +++ b/agents-api/tests/test_docs_routes.py @@ -14,7 +14,6 @@ from .utils import patch_testing_temporal -@skip @test("route: create user doc") async def _(make_request=make_request, user=test_user): async with patch_testing_temporal(): @@ -35,7 +34,6 @@ async def _(make_request=make_request, user=test_user): assert len(result["jobs"]) > 0 -@skip @test("route: create agent doc") async def _(make_request=make_request, agent=test_agent): async with patch_testing_temporal(): @@ -56,7 +54,6 @@ async def _(make_request=make_request, agent=test_agent): assert len(result["jobs"]) > 0 -@skip @test("route: delete doc") async def _(make_request=make_request, agent=test_agent): async with patch_testing_temporal(): @@ -87,7 +84,6 @@ async def _(make_request=make_request, agent=test_agent): assert response.status_code == 404 -@skip @test("route: get doc") async def _(make_request=make_request, agent=test_agent): async with patch_testing_temporal(): @@ -111,7 +107,6 @@ async def _(make_request=make_request, agent=test_agent): assert response.status_code == 200 -@skip @test("route: list user docs") def _(make_request=make_request, user=test_user): response = make_request( @@ -126,7 +121,6 @@ def _(make_request=make_request, user=test_user): assert isinstance(docs, list) -@skip @test("route: list agent docs") def _(make_request=make_request, agent=test_agent): response = make_request( @@ -141,7 +135,6 @@ def _(make_request=make_request, agent=test_agent): assert isinstance(docs, list) -@skip @test("route: list user docs with metadata filter") def _(make_request=make_request, user=test_user): response = make_request( @@ -159,7 +152,6 @@ def _(make_request=make_request, user=test_user): assert isinstance(docs, list) -@skip @test("route: list agent docs with metadata filter") def _(make_request=make_request, agent=test_agent): response = make_request( @@ -178,7 +170,8 @@ def _(make_request=make_request, agent=test_agent): # TODO: Fix this test. It fails sometimes and sometimes not. -@skip + + @test("route: search agent docs") async def _(make_request=make_request, agent=test_agent, doc=test_doc): time.sleep(0.5) @@ -226,7 +219,6 @@ async def _(make_request=make_request, user=test_user, doc=test_user_doc): assert len(docs) >= 1 -@skip @test("route: search agent docs hybrid with mmr") async def _(make_request=make_request, agent=test_agent, doc=test_doc): time.sleep(0.5) @@ -253,7 +245,6 @@ async def _(make_request=make_request, agent=test_agent, doc=test_doc): assert len(docs) >= 1 -@skip @test("routes: embed route") async def _( make_request=make_request, diff --git a/agents-api/tests/test_execution_workflow.py b/agents-api/tests/test_execution_workflow.py index 8d3f5232a..4a525e571 100644 --- a/agents-api/tests/test_execution_workflow.py +++ b/agents-api/tests/test_execution_workflow.py @@ -28,7 +28,6 @@ from .utils import patch_integration_service, patch_testing_temporal -@skip @test("workflow: evaluate step single") async def _( dsn=pg_dsn, @@ -70,7 +69,6 @@ async def _( assert result["hello"] == "world" -@skip @test("workflow: evaluate step multiple") async def _( dsn=pg_dsn, @@ -116,7 +114,6 @@ async def _( assert result["hello"] == "world" -@skip @test("workflow: variable access in expressions") async def _( dsn=pg_dsn, @@ -162,7 +159,6 @@ async def _( assert result["hello"] == data.input["test"] -@skip @test("workflow: yield step") async def _( dsn=pg_dsn, @@ -215,7 +211,6 @@ async def _( assert result["hello"] == data.input["test"] -@skip @test("workflow: sleep step") async def _( dsn=pg_dsn, @@ -269,7 +264,6 @@ async def _( assert result["hello"] == data.input["test"] -@skip @test("workflow: return step direct") async def _( dsn=pg_dsn, @@ -317,7 +311,6 @@ async def _( assert result["value"] == data.input["test"] -@skip @test("workflow: return step nested") async def _( dsn=pg_dsn, @@ -372,7 +365,6 @@ async def _( assert result["value"] == data.input["test"] -@skip @test("workflow: log step") async def _( dsn=pg_dsn, @@ -426,7 +418,6 @@ async def _( assert result["hello"] == data.input["test"] -@skip @test("workflow: log step expression fail") async def _( dsn=pg_dsn, @@ -483,7 +474,6 @@ async def _( assert result["hello"] == data.input["test"] -@skip @test("workflow: system call - list agents") async def _( dsn=pg_dsn, @@ -547,7 +537,6 @@ async def _( assert all("id" in agent for agent in result) -@skip @test("workflow: tool call api_call") async def _( dsn=pg_dsn, @@ -686,7 +675,6 @@ async def _( assert num_retries >= 2 -@skip @test("workflow: tool call integration dummy") async def _( dsn=pg_dsn, @@ -945,7 +933,6 @@ async def _( assert "for_each_step" in activities_scheduled -@skip @test("workflow: if-else step") async def _( dsn=pg_dsn, @@ -997,7 +984,6 @@ async def _( assert result["hello"] in [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] -@skip @test("workflow: switch step") async def _( dsn=pg_dsn, @@ -1058,7 +1044,6 @@ async def _( assert result["hello"] == "world" -@skip @test("workflow: for each step") async def _( dsn=pg_dsn, @@ -1109,7 +1094,6 @@ async def _( assert result[0]["hello"] == "world" -@skip @test("workflow: map reduce step") async def _( dsn=pg_dsn, @@ -1162,7 +1146,6 @@ async def _( for p in [1, 3, 5]: - @skip @test(f"workflow: map reduce step parallel (parallelism={p})") async def _( dsn=pg_dsn, @@ -1405,7 +1388,6 @@ async def _( assert result == "Hello, world!" -@skip @test("workflow: set and get steps") async def _( dsn=pg_dsn,