pipeline.infrastructure.utils.framework

The framework module contains:

  1. utility functions used by the pipeline framework;

  2. utility functions used by pipeline tasks to help process framework objects (Results, CalLibrary objects, etc.).

Functions

collect_properties(instance[, ignore])

Return the public properties of an object as a dictionary

contains_single_dish(context)

Return True if the context contains single-dish data.

flatten_dict(d[, join, lift])

gen_hash(o)

Makes a hash from a dictionary, list, tuple or set to any level, that contains only other hashable types (including any lists, tuples, sets, and dictionaries).

get_calfroms(context, vis[, caltypes])

Get the CalFroms of the requested type from the callibrary.

get_origin_input_arg(calapp, attr)

Get a single-valued task input argument from a CalApp.

get_qascores(result[, lo, hi])

get_tracebacks(result)

Get the tracebacks for the result, from any failures that may have occurred during the task.

is_top_level_task()

Return True if the callee if executing as part of a top-level task.

merge_jobs(jobs, task[, merge, ignore])

Merge jobs that are identical apart from the arguments named in ignore.

mkdir_p(path)

Emulate mkdir -p functionality.

pickle_copy(original)

pickle_load(fileobj)

plotms_iterate(jobs_and_wrappers[, iteraxis])

task_depth()

Get the number of executing tasks currently on the stack.