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 273357d commit c7a085a
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 @@ -22,7 +22,6 @@
EMBEDDING_SIZE: int = 1024


@skip
@test("workflow: evaluate step single")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -68,7 +67,6 @@ async def _(
raise ex


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


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


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


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


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


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


@skip
@test("workflow: log step")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -398,7 +390,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 @@ -453,7 +444,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 @@ -512,7 +502,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 @@ -644,7 +633,6 @@ async def _(
# assert num_retries >= 2


@skip
@test("workflow: tool call integration dummy")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -892,7 +880,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 @@ -939,7 +926,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 @@ -995,7 +981,6 @@ async def _(
assert result["hello"] == "world"


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


@skip
@test("workflow: map reduce step")
async def _(
dsn=pg_dsn,
Expand Down Expand Up @@ -1089,7 +1073,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 @@ -1324,7 +1307,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 c7a085a

Please sign in to comment.