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 ¶