mufasa.io.inputs.python_object

Classes

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

Module Contents

class mufasa.io.inputs.python_object.LocationInput(data)

Bases: mufasa.io.inputs.base.InputNode

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

property output_type: type

Type this node emits. Derived from _output_type.

Return type:

type

items() → list[mufasa.location.Location]

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().

Return type:

list[mufasa.location.Location]

get_config() → dict

Return all constructor arguments as a plain JSON-serializable dict.

Used by Graph.to_config() to serialise the pipeline. Every key must be a string; every value must be JSON-serializable.

Return type:

dict

class mufasa.io.inputs.python_object.MapInput(data)

Bases: mufasa.io.inputs.base.InputNode

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

items() → list[mufasa.map.Map]

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().

Return type:

list[mufasa.map.Map]

get_config() → dict

Return all constructor arguments as a plain JSON-serializable dict.

Used by Graph.to_config() to serialise the pipeline. Every key must be a string; every value must be JSON-serializable.

Return type:

dict