towhee.runtime.runtime_pipeline.RuntimePipeline

class towhee.runtime.runtime_pipeline.RuntimePipeline(dag_dict: Dict, max_workers: Optional[int] = None, config: Optional[dict] = None)

Bases: object

Manage the pipeline and runs it as a single instance.

Parameters:

• dag_dict (Dict) – The DAG Dictionary from the user pipeline.

• max_workers (int) – The maximum number of threads.

Methods

preload	Preload the operators.
profiler	Report the performance results after running the pipeline, and please note that you need to set tracer to True when you declare a pipeline.
reset_tracer	Reset the tracer, reset the record to None.

__call__(*inputs)

Output with ordering matching the input DataQueue.

__init__(dag_dict: Dict, max_workers: Optional[int] = None, config: Optional[dict] = None)

preload()

Preload the operators.

profiler()

Report the performance results after running the pipeline, and please note that you need to set tracer to True when you declare a pipeline.

reset_tracer()

Reset the tracer, reset the record to None.