numina.core.pipeline — Pipeline classes

DRP related classes

class numina.core.pipeline.InstrumentDRP(name, configurations, modes, pipelines, products=None, datamodel=None, version='undefined')

Description of an Instrument Data Reduction Pipeline

Parameters:

  • name (str) – Name of the instrument

  • configurations (dict of InstrumentConfiguration) –

  • modes (dict of ObservingModes) –

  • pipelines (dict of Pipeline) –

get_recipe_object(mode_name, pipeline_name='default')

Build a recipe object from a given mode name

iterate_mode_provides(modes, pipeline)

Return the mode that provides a given product

query_provides(product, pipeline='default', search=False)

Return the mode that provides a given product

search_mode_provides(product, pipeline='default')

Search the mode that provides a given product

select_configuration_old(obresult)

Select instrument configuration based on OB

select_profile(obresult)

Select instrument profile based on OB

select_profile_image(img)

Select instrument profile based on FITS

class numina.core.pipeline.ObservingMode(instrument='')

Observing modes of an Instrument.

class numina.core.pipeline.Pipeline(instrument, name, recipes, version=1, products=None, provides=None)

Base class for pipelines.

depsolve()

Load all recipes to search for products

get_recipe_object(mode)

Load recipe object, according to observing mode

load_product_class(mode)

Load recipe object, according to observing mode

load_product_object(name)

Load product object, according to name

load_recipe_object(mode)

Load recipe object, according to observing mode

provides(mode_label)

Return the ProductEntry for some mode

query_recipe(mode)

Recursive query of all calibrations required by a mode

who_provides(product_label)

Return the ProductEntry for some requirement

numina.core.pipelineload — Build pipelines from files

Build a LoadableDRP from a yaml file

numina.core.pipelineload.check_section(node, section, keys=None)

Validate keys in a section

numina.core.pipelineload.drp_load(package, resource, confclass=None)

Load the DRPS from a resource file.

numina.core.pipelineload.drp_load_data(package, data, confclass=None)

Load the DRPS from data.

Build a ResultOf query from dict

numina.core.pipelineload.load_mode(node, confclass=None)

Load one observing mdode

numina.core.pipelineload.load_mode_builder(obs_mode, node)

Load observing mode OB builder

numina.core.pipelineload.load_mode_tagger(obs_mode, node)

Load observing mode OB tagger

numina.core.pipelineload.load_mode_validator(obs_mode, node)

Load observing mode validator

numina.core.pipelineload.load_modes(node, confclass=None)

Load all observing modes