tethys.core.nodes.operators.operator_base

Module Contents

class tethys.core.nodes.operators.operator_base.OperatorBase[source]

Bases: serobj.utils.serobj_calls.SerobjCallsBase

Base abstract class for the Operator.

__getstate__(self)[source]

Serialize public attrs only

abstract process(self, data_packet: Any, stream: StreamBase, message_key: str = None, **kwargs)[source]

Process one data_packet.

Parameters

  • data_packet (Any) – any data object

  • stream (StreamBase) – any Stream instance

  • message_key (str) –

Returns

next data_packet or None

Return type

Any