pipeline.infrastructure.launcher.Pipeline

class Pipeline(context: str | None = None, loglevel: str = 'info', casa_version_check: bool = True, name: str | None = None, plotlevel: str = 'default', path_overrides: dict | None = None, processing_intents: dict | None = None)

Bases: object

Entry point for initializing the pipeline.

Responsible for creating new Context objects and loading saved Contexts from disk.

context

Context object containing the Pipeline state information.

Methods

close

Save a pickle of the Pipeline Context to a file.

__init__(context: str | None = None, loglevel: str = 'info', casa_version_check: bool = True, name: str | None = None, plotlevel: str = 'default', path_overrides: dict | None = None, processing_intents: dict | None = None) → None

Initialize the pipeline.

Creates a new Context or loads a saved Context from disk.

Parameters:

• context -- Filename of the pickled Context to load from disk. Specifying 'last' loads the last-saved Context, while passing None creates a new Context.

• loglevel -- Pipeline log level.

• casa_version_check -- Enable (True) or bypass (False) the CASA version check.

• name -- If not None, this overrides the name of the Pipeline Context if a new context needs to be created.

• plotlevel -- Pipeline plots level.

• path_overrides -- Optional dictionary containing context properties to be redefined when loading existing context (e.g., 'name').

• processing_intents -- Dictionary of processing intents for the current pipeline run.

close() → None

Save a pickle of the Pipeline Context to a file.