astromodule.pipeline.PipelineStorage#
- class PipelineStorage[source]#
The storage used share resources between pipeline stage
- Attributes:
- storage: dict
The data shared across pipeline stages
Methods
del_storage(storage_id)Delete storage defined by
storage_idhas_key(key[, storage_id])read(key[, storage_id])Retrieve the
valueidentified by akeyread_many(keys[, storage_id])Retrieve the
valuesidentified bykeyswrite(key, value[, storage_id])Stores
valueidentified by akeywrite_many([storage_id])Stores
valueidentified by akeyindata- classmethod __new__(*args, **kwargs)#