Fix for get workflow execution input and output (#38)

Element84 · Sep 7, 2023 · 40d2758 · 40d2758
1 parent 175fde3
commit 40d2758
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 10 deletions.
diff --git a/src/swoop/api/routers/jobs.py b/src/swoop/api/routers/jobs.py
@@ -287,7 +287,7 @@ async def get_workflow_execution_result(
     """
     Retrieves workflow execution output payload by jobID
     """
-    results = request.app.state.io.get_object(f"/execution/{jobID}/output.json")
+    results = request.app.state.io.get_object(f"/executions/{jobID}/output.json")
 
     if not results:
         raise HTTPException(
@@ -309,7 +309,7 @@ async def get_workflow_execution_inputs(request: Request, jobID) -> dict | APIEx
     """
     Retrieves workflow execution input payload by jobID
     """
-    payload = request.app.state.io.get_object(f"/execution/{jobID}/input.json")
+    payload = request.app.state.io.get_object(f"/executions/{jobID}/input.json")
 
     if not payload:
         raise HTTPException(

diff --git a/tests/api/test_jobs.py b/tests/api/test_jobs.py
@@ -8,11 +8,11 @@
     [
         {
             "source": "base_01",
-            "destination": "/execution/0187c88d-a9e0-788c-adcb-c0b951f8be91",
+            "destination": "/executions/0187c88d-a9e0-788c-adcb-c0b951f8be91",
         },
         {
             "source": "base_02",
-            "destination": "/execution/0187c88d-a9e0-757e-aa36-2fbb6c834cb5",
+            "destination": "/executions/0187c88d-a9e0-757e-aa36-2fbb6c834cb5",
         },
     ],
     __name__,

diff --git a/tests/conftest.py b/tests/conftest.py
@@ -136,11 +136,11 @@ def inject_io_fixture(io_fixtures, io_postfix=None, scope="module"):
     [
         {
             "source": "base_01",
-            "destination": "/execution/2595f2da-81a6-423c-84db-935e6791046e",
+            "destination": "/executions/2595f2da-81a6-423c-84db-935e6791046e",
         },
         {
             "source": "base_02",
-            "destination": "/execution/81842304-0aa9-4609-89f0-1c86819b0752",
+            "destination": "/executions/81842304-0aa9-4609-89f0-1c86819b0752",
         },
     ],
     __name__,

diff --git a/tests/test_io.py b/tests/test_io.py
@@ -8,11 +8,11 @@
     [
         {
             "source": "base_01",
-            "destination": "/execution/2595f2da-81a6-423c-84db-935e6791046e",
+            "destination": "/executions/2595f2da-81a6-423c-84db-935e6791046e",
         },
         {
             "source": "base_02",
-            "destination": "/execution/81842304-0aa9-4609-89f0-1c86819b0752",
+            "destination": "/executions/81842304-0aa9-4609-89f0-1c86819b0752",
         },
     ],
     __name__,
@@ -30,14 +30,14 @@ def test_hasbucket(test_client, bucket_name):
 
 def test_add_object(test_client, single_object):
     test_client.app.state.io.put_object(
-        "/execution/2595f2da-81a6-423c-84db-935e6791046e/io.json",
+        "/executions/2595f2da-81a6-423c-84db-935e6791046e/io.json",
         json.dumps(single_object),
     )
     assert True
 
 
 def test_remove_object(test_client):
     test_client.app.state.io.delete_object(
-        "/execution/2595f2da-81a6-423c-84db-935e6791046e/io.json"
+        "/executions/2595f2da-81a6-423c-84db-935e6791046e/io.json"
     )
     assert True