ivis.pipeline

Classes

Pipeline(path_ms, path_beams, path_sd, ...)

class ivis.pipeline.Pipeline(path_ms, path_beams, path_sd, pathout, filename, target_header, sd, beam_sd, units='Jy/arcsec^2', max_its=20, lambda_sd=0, lambda_r=1, positivity=False, device='cpu', start=0, end=4, step=1, data_processor_workers=12, imager_workers=8, beam_workers=4, queue_maxsize=4, uvmin=0, uvmax=7000, extension='.ms', blocks='single', max_blocks=None, fixms=False, precompute=False, write_mode='final')

Bases: object

init_output_fits()

preload_visibilities(vis_queue)

Preloads visibility data into a multiprocessing queue with backpressure handling.

process_visibilities(vis_queue, write_queue)

run()

write_final_cube()

write_worker(write_queue)