openarmature-python/src/openarmature/graph/__init__.py at aa79d6edcbd5d8b01f2b6a567f2c5349425d17dd · LunarCommand/openarmature-python · GitHub

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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
# Spec: this package implements the graph-engine capability. Compile-time
# and runtime error categories come from graph-engine §2 and §4.

"""Public API for the OpenArmature graph engine.

Re-exports the surface a user touches when building and running a
graph: the state schema base, reducers, the builder/compiled pair,
edge primitives and the END sentinel, the node/subgraph/projection
seams, and the canonical compile-time and runtime error categories.
"""

from .builder import GraphBuilder
from .compiled import CompiledGraph
from .edges import END, ConditionalEdge, EndSentinel, StaticEdge
from .errors import (
    CompileError,
    ConflictingReducers,
    DanglingEdge,
    EdgeException,
    FanOutCountModeAmbiguous,
    FanOutEmpty,
    FanOutFieldNotList,
    FanOutInvalidConcurrency,
    FanOutInvalidCount,
    GraphError,
    MappingReferencesUndeclaredField,
    MultipleOutgoingEdges,
    NoDeclaredEntry,
    NodeException,
    ParallelBranchesBranchFailed,
    ParallelBranchesNoBranches,
    ReducerError,
    RoutingError,
    RuntimeGraphError,
    StateValidationError,
    UnreachableNode,
)
from .events import NodeEvent
from .fan_out import FanOutConfig, FanOutNode
from .middleware import (
    Middleware,
    NextCall,
    RetryMiddleware,
    TimingMiddleware,
    TimingRecord,
    default_classifier,
    deterministic_backoff,
    exponential_jitter_backoff,
)
from .nodes import FunctionNode, Node
from .observer import DrainSummary, Observer, RemoveHandle, SubscribedObserver
from .parallel_branches import BranchSpec, ParallelBranchesNode
from .projection import ExplicitMapping, FieldNameMatching, ProjectionStrategy
from .reducers import Reducer, append, concat_flatten, last_write_wins, merge, merge_all
from .state import State
from .subgraph import SubgraphNode

__all__ = [
    "END",
    "CompileError",
    "CompiledGraph",
    "ConditionalEdge",
    "ConflictingReducers",
    "DanglingEdge",
    "DrainSummary",
    "EdgeException",
    "EndSentinel",
    "ExplicitMapping",
    "FanOutConfig",
    "FanOutCountModeAmbiguous",
    "FanOutEmpty",
    "FanOutFieldNotList",
    "FanOutInvalidConcurrency",
    "FanOutInvalidCount",
    "FanOutNode",
    "FieldNameMatching",
    "FunctionNode",
    "GraphBuilder",
    "GraphError",
    "MappingReferencesUndeclaredField",
    "Middleware",
    "MultipleOutgoingEdges",
    "NextCall",
    "Node",
    "NodeEvent",
    "NodeException",
    "NoDeclaredEntry",
    "Observer",
    "ParallelBranchesBranchFailed",
    "ParallelBranchesNoBranches",
    "ParallelBranchesNode",
    "BranchSpec",
    "ProjectionStrategy",
    "Reducer",
    "ReducerError",
    "RemoveHandle",
    "RetryMiddleware",
    "RoutingError",
    "RuntimeGraphError",
    "State",
    "StateValidationError",
    "StaticEdge",
    "SubgraphNode",
    "SubscribedObserver",
    "TimingMiddleware",
    "TimingRecord",
    "UnreachableNode",
    "append",
    "concat_flatten",
    "default_classifier",
    "deterministic_backoff",
    "exponential_jitter_backoff",
    "last_write_wins",
    "merge",
    "merge_all",
]