fix

Author: matusdrobuliak66

services/director-v2/src/simcore_service_director_v2/api/routes/computations_tasks.py

@@ -154,7 +154,7 @@ async def get_task_log_file(
     comp_tasks_repo: Annotated[
         CompTasksRepository, Depends(get_repository(CompTasksRepository))
     ],
-) -> TaskLogFileGet:
+) -> TaskLogFileGet:  # MATUS CHECK
     """Returns a link to download logs file of a give task.
     The log is only available when the task is done
     """

services/director-v2/src/simcore_service_director_v2/utils/computations.py

@@ -26,6 +26,12 @@
         RunningState.NOT_STARTED,
         RunningState.WAITING_FOR_CLUSTER,
     ): RunningState.WAITING_FOR_CLUSTER,
+    # if there are tasks waiting for resources, then the pipeline is also waiting for resources
+    (
+        RunningState.PUBLISHED,
+        RunningState.NOT_STARTED,
+        RunningState.WAITING_FOR_RESOURCES,
+    ): RunningState.WAITING_FOR_RESOURCES,
     # if there are PENDING states that means the pipeline was published and is awaiting sidecars
     (
         RunningState.PENDING,

services/director-v2/tests/unit/test_utils_computation.py

@@ -257,6 +257,15 @@ def fake_task(fake_task_file: Path) -> CompTaskAtDB:
             RunningState.WAITING_FOR_CLUSTER,
             id="published and waiting for cluster = waiting for cluster",
         ),
+        pytest.param(
+            [
+                (RunningState.WAITING_FOR_RESOURCES),
+                (RunningState.PUBLISHED),
+                (RunningState.PUBLISHED),
+            ],
+            RunningState.WAITING_FOR_RESOURCES,
+            id="published and waiting for resources = waiting for resources",
+        ),
     ],
 )
 def test_get_pipeline_state_from_task_states(