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_id

has_key(key[, storage_id])

read(key[, storage_id])

Retrieve the value identified by a key

read_many(keys[, storage_id])

Retrieve the values identified by keys

write(key, value[, storage_id])

Stores value identified by a key

write_many([storage_id])

Stores value identified by a key in data

classmethod __new__(*args, **kwargs)#