flint.prefect.flows.continuum_pipeline
======================================

.. py:module:: flint.prefect.flows.continuum_pipeline

.. autoapi-nested-parse::

   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
---------

.. autoapisummary::

   flint.prefect.flows.continuum_pipeline._check_create_output_split_science_path
   flint.prefect.flows.continuum_pipeline._check_field_options
   flint.prefect.flows.continuum_pipeline.cli
   flint.prefect.flows.continuum_pipeline.get_parser
   flint.prefect.flows.continuum_pipeline.process_science_fields
   flint.prefect.flows.continuum_pipeline.setup_run_process_science_field


Module Contents
---------------

.. py:function:: _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.

   :param science_path: The directory that contains the MSs for science processing
   :type science_path: Path
   :param split_path: Where the output MSs will be written to and processed
   :type split_path: Path
   :param check_exists: Should we check to make sure output directory does not exist. Defaults to True.
   :type check_exists: bool, optional

   :raises ValueError: Raised when the output directory exists

   :returns: The output directory
   :rtype: Path


.. py:function:: _check_field_options(field_options: flint.options.FieldOptions) -> None

.. py:function:: cli() -> None

.. py:function:: get_parser() -> configargparse.ArgumentParser

.. py:function:: process_science_fields(science_path: pathlib.Path, split_path: pathlib.Path, field_options: flint.options.FieldOptions, bandpass_path: pathlib.Path | None = None) -> None

.. py:function:: 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