flint.prefect.flows.continuum_pipeline

A prefect based pipeline that: - will perform bandpass calibration with PKS B1934-638 data, or from a derived sky-model - copy and apply to science field - image and self-calibration the science fields - run aegean source finding

Functions

_check_create_output_split_science_path(→ pathlib.Path)	Create the output path that the science MSs will be placed.
_check_field_options(→ None)
cli(→ None)
get_parser(→ configargparse.ArgumentParser)
process_science_fields(→ None)
setup_run_process_science_field(→ None)

Module Contents

flint.prefect.flows.continuum_pipeline._check_create_output_split_science_path(science_path: pathlib.Path, split_path: pathlib.Path, check_exists: bool = True) → pathlib.Path

Create the output path that the science MSs will be placed.

Parameters:

• science_path (Path) – The directory that contains the MSs for science processing

• split_path (Path) – Where the output MSs will be written to and processed

• check_exists (bool, optional) – Should we check to make sure output directory does not exist. Defaults to True.

Raises:

ValueError – Raised when the output directory exists

Returns:

The output directory

Return type:

Path

flint.prefect.flows.continuum_pipeline._check_field_options(field_options: flint.options.FieldOptions) → None

flint.prefect.flows.continuum_pipeline.cli() → None

flint.prefect.flows.continuum_pipeline.get_parser() → configargparse.ArgumentParser

flint.prefect.flows.continuum_pipeline.process_science_fields(science_path: pathlib.Path, split_path: pathlib.Path, field_options: flint.options.FieldOptions, bandpass_path: pathlib.Path | None = None) → None

flint.prefect.flows.continuum_pipeline.setup_run_process_science_field(cluster_config: str | pathlib.Path, science_path: pathlib.Path, split_path: pathlib.Path, field_options: flint.options.FieldOptions, bandpass_path: pathlib.Path | None = None) → None