File size: 1,072 Bytes
116524e
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
"""Generic pipeline engine, create and Compose pipelines, control execution mode.



Public surface::



    from pipeline import (

        Pipeline,

        Branch,

        MergeStrategy,

        StepProtocol,

        PipelineHook,

        StepContext,

        SampleResult,

        CancellationToken,

        cancel_token_var,

        PipelineOrderError,

        PipelineConfigError,

        PipelineCancelled,

        BranchError,

    )

"""

from .branch import Branch, MergeStrategy
from .context import StepContext
from .errors import BranchError, CancellationToken, PipelineCancelled, PipelineConfigError, PipelineOrderError, cancel_token_var
from .pipeline import Pipeline
from .protocol import PipelineHook, SampleResult, StepProtocol

__all__ = [
    "Pipeline",
    "Branch",
    "MergeStrategy",
    "StepProtocol",
    "PipelineHook",
    "StepContext",
    "SampleResult",
    "CancellationToken",
    "cancel_token_var",
    "PipelineOrderError",
    "PipelineConfigError",
    "PipelineCancelled",
    "BranchError",
]