mufasa.io.inputs.base#

Classes#

Base for all pipeline input nodes. Has no predecessor inputs.

class mufasa.io.inputs.base.InputNode#

Bases: mufasa.node.Node

Base for all pipeline input nodes. Has no predecessor inputs.

configure(crs, bbox, resolution) → None#

Receive spatial configuration from the Graph at construction time.

Override in nodes that need crs/bbox/resolution to initialise internal state (e.g. POM creates its map here). Default is a no-op.

abstractmethod items()#

Return items from this input in temporal order.

File-based nodes return a sorted list. Streaming nodes return a blocking generator that yields as items arrive via ingest().

run() → None#

process(*args, **kwargs) → None#

Input nodes do not receive process() calls from the framework.