astromodule.pipeline.PipelineStage#

class PipelineStage[source]#

Base class for all pipeline stages

Attributes:
storage: PipelineStorage

The pipeline storage. All resources of the pipeline are shared between stages using this object. The Pipeline class creates this object during instantiation

Methods

get_data(key)

Retrieve shared data identified by a key

log(message)

run()

All concrete class of PipelineStage must implement this method.

set_data(key, value)

Stores shared data value identified by a key

Attributes

name

products

A list of all resorces produced by this pipeline stage.

requirements

A list of all resorces required by this pipeline stage.

storage_id

classmethod __new__(*args, **kwargs)#