-
Notifications
You must be signed in to change notification settings - Fork 2
Expand file tree
/
Copy pathapi.py
More file actions
292 lines (287 loc) · 8.3 KB
/
api.py
File metadata and controls
292 lines (287 loc) · 8.3 KB
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
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
"""Public API -- MiniAutoGen Side C.
Usage::
from miniautogen.api import WorkflowRuntime, DeliberationRuntime, CompositeRuntime
This module re-exports the essential types that define MiniAutoGen's
identity as a multi-agent coordination library.
"""
from miniautogen.backends import (
AgentDriver,
BackendCapabilities,
BackendResolver,
)
from miniautogen.core.contracts import (
AgentHook,
AgentSpec,
CoordinationMode,
CoordinatorCapability,
EffectDescriptor,
EffectRecord,
EffectStatus,
EngineProfile,
ErrorCategory,
ExecutionEvent,
InMemoryMemoryProvider,
LoopStopReason,
McpServerBinding,
MemoryProfile,
MemoryProvider,
Message,
RunContext,
RunResult,
RunStatus,
RuntimeInterceptor,
SkillSpec,
StepSupervision,
SupervisionDecision,
SupervisionStrategy,
ToolSpec,
)
from miniautogen.core.contracts.agent import (
ConversationalAgent,
DeliberationAgent,
WorkflowAgent,
)
from miniautogen.core.contracts.agentic_loop import (
AgenticLoopState,
ConversationPolicy,
RouterDecision,
)
from miniautogen.core.contracts.conversation import Conversation
from miniautogen.core.contracts.coordination import (
AgenticLoopPlan,
CoordinationKind,
CoordinationPlan,
DeliberationPlan,
SubrunRequest,
WorkflowPlan,
WorkflowStep,
)
from miniautogen.core.contracts.delegation import (
DelegationRouterProtocol,
PersistableMemory,
)
from miniautogen.core.contracts.deliberation import (
Contribution,
Review,
)
from miniautogen.core.contracts.store import StoreProtocol
from miniautogen.core.contracts.tool import ToolProtocol, ToolResult
from miniautogen.core.contracts.tool_registry import (
ToolCall,
ToolDefinition,
ToolRegistryProtocol,
)
from miniautogen.core.contracts.turn_result import TurnResult
from miniautogen.core.effect_interceptor import EffectInterceptor
from miniautogen.core.runtime.agent_runtime import AgentRuntime
from miniautogen.core.runtime.tool_registry import InMemoryToolRegistry
from miniautogen.core.runtime.delegation_router import ConfigDelegationRouter
from miniautogen.core.runtime.persistent_memory import PersistentMemoryProvider
from miniautogen.core.runtime.filesystem_tool_registry import FileSystemToolRegistry
from miniautogen.core.events.event_sink import (
CompositeEventSink,
EventSink,
FilteredEventSink,
InMemoryEventSink,
NullEventSink,
)
from miniautogen.core.events.filters import (
CompositeFilter,
EventFilter,
RunFilter,
TypeFilter,
)
from miniautogen.core.events.types import EventType
from miniautogen.core.runtime import (
AgenticLoopRuntime,
CompositeRuntime,
DeliberationRuntime,
PipelineRunner,
WorkflowRuntime,
)
from miniautogen.core.runtime.agent_runtime import AgentRuntime
from miniautogen.core.runtime.builtin_tools import BuiltinToolRegistry
from miniautogen.core.runtime.composite_runtime import CompositionStep
from miniautogen.core.runtime.composite_tool_registry import CompositeToolRegistry
from miniautogen.core.runtime.delegation_router import ConfigDelegationRouter
from miniautogen.core.runtime.filesystem_tool_registry import FileSystemToolRegistry
from miniautogen.core.runtime.human_agent import (
HumanAgent,
InputChannel,
QueueInputChannel,
StdinInputChannel,
)
from miniautogen.core.runtime.persistent_memory import PersistentMemoryProvider
from miniautogen.core.runtime.recovery import SessionRecovery
from miniautogen.core.runtime.tool_registry import InMemoryToolRegistry
from miniautogen.observability.event_logging import LoggingEventSink
from miniautogen.pipeline.components.pipelinecomponent import PipelineComponent
from miniautogen.pipeline.pipeline import Pipeline
from miniautogen.policies.approval import ApprovalGate, AutoApproveGate
from miniautogen.policies.approval_channel import (
ApprovalChannel,
ApprovalHandle,
CallbackApprovalChannel,
ChannelApprovalGate,
InMemoryApprovalChannel,
WebhookApprovalChannel,
)
from miniautogen.policies.budget import BudgetExceededError, BudgetPolicy, BudgetTracker
from miniautogen.policies.chain import PolicyChain, PolicyContext, PolicyEvaluator, PolicyResult
from miniautogen.policies.effect import EffectPolicy
from miniautogen.policies.execution import ExecutionPolicy
from miniautogen.policies.retry import RetryPolicy
from miniautogen.policies.semantic_cache import ExactCache, SemanticCache
from miniautogen.scripting import ScriptBuilder, quick_run
from miniautogen.stores.checkpoint_store import CheckpointStore
from miniautogen.stores.effect_journal import EffectJournal
from miniautogen.stores.in_memory_checkpoint_store import InMemoryCheckpointStore
from miniautogen.stores.in_memory_effect_journal import InMemoryEffectJournal
from miniautogen.stores.in_memory_run_store import InMemoryRunStore
from miniautogen.stores.run_store import RunStore
from miniautogen.stores.sqlalchemy_checkpoint_store import SQLAlchemyCheckpointStore
from miniautogen.stores.sqlalchemy_run_store import SQLAlchemyRunStore
from miniautogen.testing import MockEngine, RecordReplayEngine
__all__ = [
# Core contracts
"AgentSpec",
"EngineProfile",
"ExecutionEvent",
"LoopStopReason",
"McpServerBinding",
"MemoryProfile",
"Message",
"RunContext",
"RunResult",
"RunStatus",
"SkillSpec",
"StoreProtocol",
"ToolProtocol",
"ToolResult",
"ToolSpec",
"ToolRegistryProtocol",
"ToolDefinition",
"ToolCall",
"DelegationRouterProtocol",
"PersistableMemory",
"TurnResult",
"Conversation",
# Agent protocols
"WorkflowAgent",
"DeliberationAgent",
"ConversationalAgent",
# Agent hooks and memory
"AgentHook",
"MemoryProvider",
"InMemoryMemoryProvider",
# Agentic loop
"RouterDecision",
"ConversationPolicy",
"AgenticLoopState",
"AgenticLoopPlan",
# Deliberation (general + specialized)
"Contribution",
"Review",
# Coordination
"CoordinationKind",
"CoordinationMode",
"CoordinationPlan",
"DeliberationPlan",
"WorkflowPlan",
"WorkflowStep",
"CompositionStep",
"SubrunRequest",
"CoordinatorCapability",
# Runtimes (Coordination Modes)
"AgenticLoopRuntime",
"CompositeRuntime",
"DeliberationRuntime",
"PipelineRunner",
"WorkflowRuntime",
# Agent runtime and tools
"AgentRuntime",
"BuiltinToolRegistry",
"CompositeToolRegistry",
"InMemoryToolRegistry",
"FileSystemToolRegistry",
"ConfigDelegationRouter",
"PersistentMemoryProvider",
# Runtime interceptor
"RuntimeInterceptor",
# Pipeline
"Pipeline",
"PipelineComponent",
# Policy enforcement
"PolicyChain",
"PolicyContext",
"PolicyResult",
"PolicyEvaluator",
"RetryPolicy",
"BudgetPolicy",
"BudgetTracker",
"BudgetExceededError",
"ExecutionPolicy",
# Approval
"ApprovalGate",
"AutoApproveGate",
# Approval channels (decoupled human-in-the-loop)
"ApprovalChannel",
"ApprovalHandle",
"CallbackApprovalChannel",
"ChannelApprovalGate",
"InMemoryApprovalChannel",
"WebhookApprovalChannel",
# Scripting mode
"ScriptBuilder",
"quick_run",
# Testing (MockEngine, RecordReplay)
"MockEngine",
"RecordReplayEngine",
# Semantic cache
"ExactCache",
"SemanticCache",
# HumanAgent (human-as-first-class participant)
"HumanAgent",
"InputChannel",
"QueueInputChannel",
"StdinInputChannel",
# Effect engine
"EffectInterceptor",
"EffectPolicy",
"EffectDescriptor",
"EffectRecord",
"EffectStatus",
# Supervision
"StepSupervision",
"SupervisionDecision",
"SupervisionStrategy",
# Error taxonomy
"ErrorCategory",
# Events and observability
"EventType",
"EventSink",
"NullEventSink",
"CompositeEventSink",
"CompositeFilter",
"EventFilter",
"FilteredEventSink",
"InMemoryEventSink",
"LoggingEventSink",
"RunFilter",
"TypeFilter",
# Recovery
"SessionRecovery",
# Backend driver abstraction
"AgentDriver",
"BackendCapabilities",
"BackendResolver",
# Stores
"CheckpointStore",
"InMemoryCheckpointStore",
"EffectJournal",
"InMemoryEffectJournal",
"InMemoryRunStore",
"RunStore",
"SQLAlchemyCheckpointStore",
"SQLAlchemyRunStore",
]