towhee.engine.operator_runner.flatmap_runner.FlatMapRunner¶
- class towhee.engine.operator_runner.flatmap_runner.FlatMapRunner(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
FlatMap, one input multiple outputs.
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 ¶