towhee.engine.operator_runner.concat_runner.ConcatRunner

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

Bases: towhee.engine.operator_runner.runner_base.RunnerBase

Concat wrapper, multiple inputs one output.

Concat can not run in multi-thread.

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[source]

Initialize self. See help(type(self)) for accurate signature.