towhee.engine.operator_runner.window_runner.WindowRunner¶

class towhee.engine.operator_runner.window_runner.WindowRunner(name: str, index: int, op_name: str, tag: str, hub_op_id: str, op_args: Dict[str, any], readers=None, writer=None)[source]¶

Bases: RunnerBase

WindowRunner, multiple inputs and multiple outputs.

Wrapper will run in task executor in another thread or process. If run an op error, we should pass error info by an error handler.

Methods

`is_end`
`is_finished`
`is_idle`
`join`
`process`
`process_step`
`set_op`
`set_stop`
`sleep`
`slow_down`
`speed_up`
`unset_op`

Attributes

`hub_op_id`
`msg`
`op`
`op_args`
`op_name`
`status`
`tag`

__init__(name: str, index: int, op_name: str, tag: str, hub_op_id: str, op_args: Dict[str, any], readers=None, writer=None) → None¶