Skip to content

Commit

Permalink
chore: Unskip tests
Browse files Browse the repository at this point in the history
  • Loading branch information
whiterabbit1983 committed Dec 27, 2024
1 parent f06439f commit fece441
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 29 deletions.
13 changes: 2 additions & 11 deletions agents-api/tests/test_docs_routes.py
Original file line number Diff line number Diff line change
Expand Up @@ -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():
Expand All @@ -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():
Expand All @@ -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():
Expand Down Expand Up @@ -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():
Expand All @@ -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(
Expand All @@ -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(
Expand All @@ -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(
Expand All @@ -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(
Expand All @@ -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)
Expand Down Expand Up @@ -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)
Expand All @@ -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,
Expand Down
18 changes: 0 additions & 18 deletions agents-api/tests/test_execution_workflow.py
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@
from .utils import patch_integration_service, patch_testing_temporal


@skip
@test("workflow: evaluate step single")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -70,7 +69,6 @@ async def _(
assert result["hello"] == "world"


@skip
@test("workflow: evaluate step multiple")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -116,7 +114,6 @@ async def _(
assert result["hello"] == "world"


@skip
@test("workflow: variable access in expressions")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -162,7 +159,6 @@ async def _(
assert result["hello"] == data.input["test"]


@skip
@test("workflow: yield step")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -215,7 +211,6 @@ async def _(
assert result["hello"] == data.input["test"]


@skip
@test("workflow: sleep step")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -269,7 +264,6 @@ async def _(
assert result["hello"] == data.input["test"]


@skip
@test("workflow: return step direct")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -317,7 +311,6 @@ async def _(
assert result["value"] == data.input["test"]


@skip
@test("workflow: return step nested")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -372,7 +365,6 @@ async def _(
assert result["value"] == data.input["test"]


@skip
@test("workflow: log step")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -426,7 +418,6 @@ async def _(
assert result["hello"] == data.input["test"]


@skip
@test("workflow: log step expression fail")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -483,7 +474,6 @@ async def _(
assert result["hello"] == data.input["test"]


@skip
@test("workflow: system call - list agents")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -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,
Expand Down Expand Up @@ -686,7 +675,6 @@ async def _(
assert num_retries >= 2


@skip
@test("workflow: tool call integration dummy")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -945,7 +933,6 @@ async def _(
assert "for_each_step" in activities_scheduled


@skip
@test("workflow: if-else step")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -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,
Expand Down Expand Up @@ -1058,7 +1044,6 @@ async def _(
assert result["hello"] == "world"


@skip
@test("workflow: for each step")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -1109,7 +1094,6 @@ async def _(
assert result[0]["hello"] == "world"


@skip
@test("workflow: map reduce step")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -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,
Expand Down Expand Up @@ -1405,7 +1388,6 @@ async def _(
assert result == "Hello, world!"


@skip
@test("workflow: set and get steps")
async def _(
dsn=pg_dsn,
Expand Down

0 comments on commit fece441

Please sign in to comment.