:py:mod:`process_sefd`
======================

.. py:module:: process_sefd


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


Functions
~~~~~~~~~

.. autoapisummary::

   process_sefd.process_sefd
   process_sefd.setup_sefd_flow
   process_sefd.cli



Attributes
~~~~~~~~~~

.. autoapisummary::

   process_sefd.logger
   process_sefd.task_summary_sefd
   process_sefd.task_merge_sefd
   process_sefd.task_processing_sefd
   process_sefd.task_scan_ms_configs
   process_sefd.task_create_parset
   process_sefd.task_move_sefd_files_info


.. py:data:: logger

   

.. py:data:: task_summary_sefd

   

.. py:data:: task_merge_sefd

   

.. py:data:: task_processing_sefd

   

.. py:data:: task_scan_ms_configs

   

.. py:data:: task_create_parset

   

.. py:data:: task_move_sefd_files_info

   

.. py:function:: process_sefd(sbid: int, sefd_path: pathlib.Path = None) -> None

   Main prefect flow to perform the SEFD processing and analysis.

   Args:
       sbid (int): SBID of the observation data. A folder with these measurement sets should be in the current directory.
       sefd_path (Path, optional): If not None, the SEFD data products will be copied to this directory. An attempt will be made to created the directory if it does not exist. Defaults to None. 
       
   Raises:
       MissingBeamError: Raised when on of the 36 ASKAP beams is missing


.. py:function:: setup_sefd_flow(sbid: int, cluster: str, workdir: pathlib.Path = None, schedule_block_path: pathlib.Path = None, emit_clink: bool = False, sefd_path: pathlib.Path = None) -> None

   Perform basic checks before starting the main SEFD processing workflow

   Args:
       sbid (int): SBID of observation to process
       cluster (str): Known cluster configuration file for the DaskTaskRunner packaged with aces-apps
       workdir (Path, optional): Where to carry out the computation. If None, the current working directory will be used. Defaults to None.
       schedule_block_path (Path, optional): Path to the space on disk where the Measurement sets are stored (inside a SBID folder). If not None and the SBID folder exists with the 36 measurementsets, these are copied over and delete the measurments in the workdir, if they exists. Defaults to None.
       emit_clink (bool, optional): If True, a clink event will be sent to advertise the processing completeion. Defaults to False.
       sefd_path (Path, optional): If not None, the SEFD data products will be copied to this directory. An attempt will be made to created the directory if it does not exist. Defaults to None. 


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

   CLI entry point for the SEFD processing pipeline