process_sefd

Module Contents

Functions

process_sefd(→ None)

Main prefect flow to perform the SEFD processing and analysis.

setup_sefd_flow(→ None)

Perform basic checks before starting the main SEFD processing workflow

cli(→ None)

CLI entry point for the SEFD processing pipeline

Attributes

logger

task_summary_sefd

task_merge_sefd

task_processing_sefd

task_scan_ms_configs

task_create_parset

task_move_sefd_files_info

process_sefd.logger[source]
process_sefd.task_summary_sefd[source]
process_sefd.task_merge_sefd[source]
process_sefd.task_processing_sefd[source]
process_sefd.task_scan_ms_configs[source]
process_sefd.task_create_parset[source]
process_sefd.task_move_sefd_files_info[source]
process_sefd.process_sefd(sbid: int, sefd_path: pathlib.Path = None) → None[source]

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

process_sefd.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[source]

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.

process_sefd.cli() → None[source]

CLI entry point for the SEFD processing pipeline