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