pipeline.infrastructure.sessionutils

Functions

as_list(o)
get_spwmap(source_ms, target_ms)	Get a map of spectral windows IDs that map from a source spw ID in the source MS to its equivalent spw in the target MS.
get_vislist_for_session(context, session)	Return list of measurement sets for specified session name.
group_into_sessions(context, all_results)	Return results grouped into lists by session.
group_vislist_into_sessions(context, vislist)	Group the specified list of measurement sets ‘vislist’ by their session, and return a dictionary that maps a session name to the corresponding list of measurement sets.
parallel_inputs_impl()	Get a vis-independent property implementation for a parallel Inputs argument.
remap_spw_int(source_ms, target_ms, spws)	Map integer spw arguments from one MS to their equivalent spw in the target ms.
remap_spw_str(source_ms, target_ms, spws)	Remap a string spw argument, e.g., ‘16,18,20,22’, from one MS to the equivalent map in the target ms.
remove_unexpected_args(fn, fn_args)
validate_args(inputs_cls, task_args)

Classes

ParallelTemplate(inputs)
VDPTaskFactory(inputs, executor, task)	VDPTaskFactory is a class that implements the Factory design pattern, returning tasks that execute on an MPI client or locally as appropriate.
VisResultTuple(vis, inputs, result)