@sanderegg analyze_pipeline -> validate_pipeline

Author: bisgaard-itis

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

@@ -83,7 +83,7 @@
 from ..dependencies.database import get_repository
 from ..dependencies.rabbitmq import rabbitmq_rpc_client
 from ..dependencies.rut_client import get_rut_client
-from .computations_tasks import analyze_pipeline
+from .computations_tasks import validate_pipeline
 
 _PIPELINE_ABORT_TIMEOUT_S: Final[timedelta] = timedelta(seconds=30)
 
@@ -453,7 +453,7 @@ async def get_computation(
     # check that project actually exists
     await project_repo.get_project(project_id)
 
-    pipeline_dag, all_tasks, _filtered_tasks = await analyze_pipeline(
+    pipeline_dag, all_tasks, _filtered_tasks = await validate_pipeline(
         project_id, comp_pipelines_repo, comp_tasks_repo
     )
 

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

@@ -35,7 +35,7 @@
 # HELPERS -------------------------------------------------------------------
 
 
-async def analyze_pipeline(
+async def validate_pipeline(
     project_id: ProjectID,
     comp_pipelines_repo: CompPipelinesRepository,
     comp_tasks_repo: CompTasksRepository,
@@ -82,7 +82,7 @@ async def get_all_tasks_log_files(
     Each log is only available when the corresponding task is done
     """
     # gets computation task ids
-    info = await analyze_pipeline(project_id, comp_pipelines_repo, comp_tasks_repo)
+    info = await validate_pipeline(project_id, comp_pipelines_repo, comp_tasks_repo)
     iter_task_ids = (t.node_id for t in info.filtered_tasks)
 
     tasks_logs_files: list[TaskLogFileGet] = await logged_gather(