towhee.engine.operator_context.OperatorContext¶

class towhee.engine.operator_context.OperatorContext(op_repr: OperatorRepr, dataframes: Dict[str, DataFrame])[source]¶

Bases: object

The OperatorContext manages an operator’s input data and output data at runtime, as well as the operators’ dependency within a GraphContext. The abstraction of OperatorContext hides the complexity of Dataframe management, input iteration, and data dependency between Operators. It offers a Task-based scheduling context. :param op_repr: (OperatorRepr)

The operator representation

Parameters:: dataframes – (dict of DataFrame) All the DataFrames in GraphContext

Methods

`join`
`slow_down`
`speed_up`
`start`
`stop`

Attributes

`err_msg`
`name`
`status`	Calc op-ctx status by checking all runners of this op-ctx

__init__(op_repr: OperatorRepr, dataframes: Dict[str, DataFrame])[source]¶

property status¶: Calc op-ctx status by checking all runners of this op-ctx