pipeline.infrastructure.callibrary

Functions

ant_add(td1, td2[, join])

ant_sub(td1, td2[, join])

consolidate_calibrations(all_my_calapps)

Consolidate a list of (CalTo, [CalFrom..]) 2-tuples into a smaller set of equivalent applications by consolidating their data selection arguments.

contiguous_sequences(l)

Group a sequence of numbers into contiguous groups

copy_calapplication(calapp[, origin])

Copy a CalApplication, overwriting any CalTo or CalFrom values with the given override values.

create_data_reducer(join)

Return a function that creates a new TimestampedData object containing the result of executing the given operation on two TimestampedData objects.

create_interval_tree(a)

Create an IntervalTree containing a set of Intervals.

create_interval_tree_for_ms(ms)

Create a new IntervalTree fitted to the dimensions of a measurement set.

create_interval_tree_nd(intervals, value_fn)

Create a multidimensional IntervalTree.

data_selection_contains(proposed, calto_args)

Return True if one data selection is contained within another.

defrag_interval_tree(tree)

Condense an IntervalTree by consolidating fragmented entries with the same value into contiguous Intervals.

expand_calstate(calstate)

Convert an IntervalCalState into the equivalent consolidated list of (CalTo, [CalFrom..]) 2-tuples.

expand_calstate_to_calapps(calstate)

Convert an IntervalCalState into a list of (CalTo, [CalFrom..]) tuples.

expand_interval(interval, calto_args, calto_fn)

Convert an Interval into the equivalent list of (CalTo, [CalFrom..]) 2-tuples.

expand_intervaltree(tree, convert_fns, calto_fn)

Convert an IntervalTree into the equivalent list of (CalTo, [CalFrom..]) 2-tuples.

field_add(td1, td2[, join])

field_sub(td1, td2[, join])

fix_cycle0_data_selection(context, calstate)

get_calstate_shape(ms)

Get an IntervalTree shaped to the dimensions of the given measurement set.

get_calto_from_inputs(inputs)

Get a CalTo data selection object based on the state of an Inputs object

get_id_to_field_fn(ms_to_id_to_field)

Return a function that can convert field IDs to a field name.

get_id_to_intent_fn(id_to_intent)

Return a function that can convert intent IDs to a string intent.

get_intent_id_map(ms)

Get the mapping of intent ID to string intent for a measurement set.

get_matching_calstate(context, calstate, …)

Return an IntervalCalState contain calibrations in the input IntervalCalState that match the predicate function.

get_min_max(l[, keyfunc])

intent_add(td1, td2[, join])

intent_sub(td1, td2[, join])

interval_to_set(interval)

Get the all the indexes covered by an Interval.

merge_contiguous_intervals(tree)

Merge contiguous Intervals with the same value into one Interval.

merge_intervaltrees(on_intersect)

Return a function that merges two IntervalTrees, executing a function on the intersecting Interval ranges in the resulting merged IntervalTree.

merge_lists([join_fn])

Return a function that merge two lists by calling the input operation on the two input arguments.

ranges(lst)

safe_join(vals[, separator])

sequence_to_casa_range(seq)

sequence_to_range(l)

set_calstate_marker(calstate, marker)

Return a copy of a calstate, modified so that TimeStampedData objects in the final leaf node are annotated with the given marker object.

spw_add(td1, td2[, join])

spw_sub(td1, td2[, join])

trim(tree, ranges)

Return an IntervalTree trimmed to the specified ranges.

trim_nd(tree, selection)

Return an IntervalTree with each dimension trimmed to the specified set of ranges.

trim_to_valid_data_selection(calstate[, vis])

Trim an IntervalCalState to the shape of valid (present) data selections.

unit(x)

Classes

CalAppOrigin(task, inputs)

CalApplication(calto, calfrom[, origin])

CalApplication maps calibration tables and their application arguments to

CalFrom([gaintable, gainfield, interp, …])

CalFrom represents a calibration table and the CASA arguments that should be used when applying that calibration table.

CalLibrary

alias of pipeline.infrastructure.callibrary.IntervalCalLibrary

CalState

alias of pipeline.infrastructure.callibrary.IntervalCalState

CalTo([vis, field, spw, antenna, intent])

CalTo represents a target data selection to which a calibration can be applied.

CalToArgs(vis, spw, field, intent, antenna)

CalToIdAdapter(context, calto)

CalToIntervalAdapter(context, calto)

DictCalLibrary(context)

CalLibrary is the root object for the pipeline calibration state.

DictCalState([default_factory])

DictCalState is a data structure used to map calibrations for all data registered with the pipeline.

IntervalCalLibrary(context)

CalLibrary is the root object for the pipeline calibration state.

IntervalCalState()

CalState is a data structure used to map calibrations for all data registered with the pipeline.

TimestampedData(time, data[, marker])