orca.tasks.imaging_peel_pipeline

Peeled imaging pipeline Celery task.

Implements a complete imaging pipeline with peeling:

copy → applycal → flag_ants → AOFlagger → TTCal peel → WSClean

Results are generated on NVMe scratch and moved to Lustre on completion.

This module extends the base imaging_tasks without modifying them.

Attributes

LOG

Functions

peel_with_ttcal_maxiter5(ms, sources)	Run TTCal peeling with reduced iteration count.
peel_imaging_pipeline_task(→ Dict[str, str])	Full-featured imaging pipeline added on top of the old tasks.

Module Contents

orca.tasks.imaging_peel_pipeline.peel_with_ttcal_maxiter5(ms: str, sources: str)

Run TTCal peeling with reduced iteration count.

Local wrapper forcing –maxiter=5 for faster peeling.

Parameters:

• ms – Path to measurement set.

• sources – Path to sources.json file.

Raises:

RuntimeError – If TTCal returns non-zero exit code.

orca.tasks.imaging_peel_pipeline.LOG

orca.tasks.imaging_peel_pipeline.peel_imaging_pipeline_task(self, ms_path: str, delay_table: str, bandpass_table: str, final_dir: str, bad_corrs: List[int] | None = None, aoflag_strategy: str | None = 'LWA_opt_GH1.lua', peel_sources_json: str | None = '/home/pipeline/sources.json', extra_wsclean: List[str] | None = None) → Dict[str, str]

Full-featured imaging pipeline added on top of the old tasks.

Returns {‘dirty_png’: <file>, ‘workspace’: <directory>}