refactor: Removed unnecessary Task method & table

Author: Alan Christie

tests/instance_launcher.py

@@ -80,8 +80,7 @@ def launch(self, launch_parameters: LaunchParameters) -> LaunchResult:
             running_workflow_step_id=launch_parameters.running_workflow_step_id
         )
         instance_id = response["id"]
-        response = self._api_adapter.create_task()
-        task_id = response["id"]
+        task_id = "task-00000000-0000-0000-0000-000000000001"
 
         # Apply variables to the step's Job command.
         job = self._api_adapter.get_job(

tests/test_test_api_adapter.py

@@ -265,14 +265,3 @@ def test_create_and_get_instance():
 
     # Assert
     assert response["running_workflow_step"] == "r-workflow-step-000"
-
-
-def test_create_task():
-    # Arrange
-    utaa = UnitTestWorkflowAPIAdapter()
-
-    # Act
-    response = utaa.create_task()
-
-    # Assert
-    assert "id" in response

tests/wapi_adapter.py

@@ -34,7 +34,6 @@
 
 # Table UUID formats
 _INSTANCE_ID_FORMAT: str = "instance-00000000-0000-0000-0000-{id:012d}"
-_TASK_ID_FORMAT: str = "task-00000000-0000-0000-0000-{id:012d}"
 _WORKFLOW_DEFINITION_ID_FORMAT: str = "workflow-00000000-0000-0000-0000-{id:012d}"
 _RUNNING_WORKFLOW_ID_FORMAT: str = "r-workflow-00000000-0000-0000-0000-{id:012d}"
 _RUNNING_WORKFLOW_STEP_ID_FORMAT: str = (
@@ -49,7 +48,6 @@
     f"{_PICKLE_DIRECTORY}/running-workflow-step.pickle"
 )
 _INSTANCE_PICKLE_FILE: str = f"{_PICKLE_DIRECTORY}/instance.pickle"
-_TASK_PICKLE_FILE: str = f"{_PICKLE_DIRECTORY}/task.pickle"
 
 
 class UnitTestWorkflowAPIAdapter(WorkflowAPIAdapter):
@@ -74,7 +72,6 @@ def __init__(self):
             _RUNNING_WORKFLOW_PICKLE_FILE,
             _RUNNING_WORKFLOW_STEP_PICKLE_FILE,
             _INSTANCE_PICKLE_FILE,
-            _TASK_PICKLE_FILE,
         ]:
             with open(file, "wb") as pickle_file:
                 Pickler(pickle_file).dump({})
@@ -282,22 +279,3 @@ def create_instance(self, *, running_workflow_step_id: str) -> dict[str, Any]:
         UnitTestWorkflowAPIAdapter.lock.release()
 
         return {"id": instance_id}
-
-    def create_task(self) -> dict[str, Any]:
-        UnitTestWorkflowAPIAdapter.lock.acquire()
-        with open(_TASK_PICKLE_FILE, "rb") as pickle_file:
-            tasks = Unpickler(pickle_file).load()
-
-        next_id: int = len(tasks) + 1
-        task_id: str = _TASK_ID_FORMAT.format(id=next_id)
-        record = {
-            "done": False,
-            "exit_code": 0,
-        }
-        tasks[task_id] = record
-
-        with open(_TASK_PICKLE_FILE, "wb") as pickle_file:
-            Pickler(pickle_file).dump(tasks)
-        UnitTestWorkflowAPIAdapter.lock.release()
-
-        return {"id": task_id}