pipeline.hsd.tasks.common.utils

Functions

TableSelector(name, query)

asdm_name(scantable_object)

Return ASDM name that target scantable belongs to. Assumptions are: - scantable is generated from MS - MS is generated from ASDM - MS name is <uid>.ms.

asdm_name_from_ms(ms_domain)

Return ASDM name that target ms originates from. Assumptions are: - MS is generated from ASDM - MS name is <uid>.ms.

create_parallel_job(task_cls, task_args, context)

create_serial_job(task_cls, task_args, context)

get_brightness_unit(vis[, defaultunit])

get_datacolumn_name(vis)

get_index_list_for_ms(datatable, vis_list, …)

get_index_list_for_ms2(datatable, …[, srctype])

get_index_list_for_ms3(datatable_dict, …)

get_mask_from_flagtra(flagtra)

Convert FLAGTRA (unsigned char) to a mask array (1=valid, 0=flagged)

get_parent_ms_idx(context, msname)

Returns index of corresponding ms in context The method maps both work_data and original MS to a proper index The return value is -1 if no match found.

get_parent_ms_name(context, msname)

Returns name of corresponding parent ms in context The method maps both work_data and original MS to a proper index The return value is “” if no match found.

get_restfrequency(vis, spwid, source_id)

get_spw_names(vis)

get_spw_properties(vis)

get_valid_ms_members(group_desc, …)

get_valid_ms_members2(group_desc, ms_filter, …)

is_nro(context)

iterate_group_member(group_desc, member_id_list)

make_ddid_map(vis)

make_polid_map(srcvis, dstvis)

make_row_map(src_ms, derived_vis[, src_tb, …])

Make row mapping between source MS and associating MS

make_row_map_for_baselined_ms(ms[, …])

Make row mapping between calibrated MS and baselined MS.

make_spwid_map(srcvis, dstvis)

mjd_to_datestring(t[, unit])

MJD —> date string

parseEdge(edge)

profiler(func)

require_virtual_spw_id_handling(observing_run)

Judge if spw ids vary across EBs.

sort_fields(context)

to_bool(s)

to_list(s)

to_numeric(s)

Classes

EchoDictionary

OnDemandStringParseLogger(logger)

ProgressTimer([length, maxCount, LogLevel])

RGAccumulator()

SpwDetailedView(spwid, name, num_channels, …)

SpwSimpleView(spwid, name)