run_named_tasks

run_named_tasks(tasks: list[tuple[str, dict[str, Any]]]) → Context[source]

Run a sequence of pipeline tasks specified by name and argument dicts.

This utility centralizes the logic previously duplicated in the test framework so that component tests and other callers can invoke a consistent execution path with uniform logging and error handling.

The function will:

  1. Initialize a fresh pipeline context via cli.h_init().

  2. Resolve each task name to a callable using cli.get_pipeline_task_with_name.

  3. Execute tasks in order, logging the call signature.

  4. Raise exceptions.PipelineException immediately if any task result reports tracebacks (handled inside _execute_task).

  5. Save the context via cli.h_save().

Parameters:

tasks -- Ordered list of (task_name, task_args_dict) tuples.

Returns:

Context -- The final pipeline context (the most recent / 'last').

Raises:

exceptions.PipelineException -- If any executed task reports tracebacks.