tethys.core.nodes.operators.balancing.operator_round_robin

Module Contents

class tethys.core.nodes.operators.balancing.operator_round_robin.RoundRobinBalancerOperator[source]

Bases: tethys.core.nodes.operators.operator_base.OperatorBase

This operator distributes data_packets between forward nodes (with round-robin algorithm)

process(self, data_packet: Any, stream: ZeroStream, **kwargs)[source]

Resend data_packet to one of the forward nodes.

Parameters

  • data_packet – any data object

  • stream (StreamBase) – Any stream

Returns

None