Skip to content

[BREAKING] Python: Refactor orchestrations #3023

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
TaoChenOSU merged 29 commits into from
Jan 13, 2026
Merged

[BREAKING] Python: Refactor orchestrations #3023

Show file tree
Hide file tree
Changes from 8 commits
Commits
Show all changes
29 commits
Select commit Hold shift + click to select a range
dbe5ff1
Group chat refactoring Part 1; Next: HIL and handoff
TaoChenOSU Dec 18, 2025
16ae7fe
Add agent approval flow; next samples
TaoChenOSU Dec 19, 2025
fc0268c
WIP: samples
TaoChenOSU Dec 19, 2025
e46ccf9
Merge branch 'main' into local-branch-python-group-chat-refactoring
TaoChenOSU Dec 19, 2025
3d5b831
WIP: HIL samples
TaoChenOSU Dec 20, 2025
5901421
Group chat HIL working; next: handoff
TaoChenOSU Dec 20, 2025
c9e7286
Fix group chat tool approval sample
TaoChenOSU Dec 22, 2025
aa5edbf
WIP: refactor handoff; next handoff handling
TaoChenOSU Dec 23, 2025
c6e5121
Handoff done; next handoff samples and concurrent and sequential
TaoChenOSU Dec 24, 2025
60fd7f0
Handoff samples, concurrent, and sequential done; next Magentic
TaoChenOSU Dec 25, 2025
b555421
WIP: magentic; next test with samples + HIL
TaoChenOSU Dec 26, 2025
b808c18
Magentic Working; next fix all samples and tests
TaoChenOSU Dec 27, 2025
36d908c
Fix handoff samples; next tests
TaoChenOSU Dec 27, 2025
c4e7c66
WIP: fixing tests; some orchestration as agent samples are failing
TaoChenOSU Dec 27, 2025
d9d371e
Group chat unit tests done
TaoChenOSU Jan 5, 2026
b2d918e
Handoff unit tests done
TaoChenOSU Jan 5, 2026
9b6a273
Remove old orchestration_request_info and fix related tests
TaoChenOSU Jan 6, 2026
a362161
Magentic unit tests done
TaoChenOSU Jan 6, 2026
22d56ca
Fix samples
TaoChenOSU Jan 7, 2026
c003804
Merge branch 'main' into local-branch-python-group-chat-refactoring
TaoChenOSU Jan 7, 2026
2d5110c
Fix test
TaoChenOSU Jan 7, 2026
8070a6d
Fix test 2
TaoChenOSU Jan 7, 2026
4540771
mypy
TaoChenOSU Jan 7, 2026
b018eab
Address comments
TaoChenOSU Jan 7, 2026
11678e5
Update readme
TaoChenOSU Jan 7, 2026
0cbef2f
Address comments
TaoChenOSU Jan 8, 2026
d241065
Address comments 2
TaoChenOSU Jan 8, 2026
e7dcaa1
Replace display name
TaoChenOSU Jan 9, 2026
ba5befc
Merge branch 'main' into local-branch-python-group-chat-refactoring
TaoChenOSU Jan 13, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
106 changes: 48 additions & 58 deletions python/packages/core/agent_framework/_workflows/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
AgentExecutorRequest,
AgentExecutorResponse,
)
from ._base_group_chat_orchestrator import GroupChatRequestSentEvent, GroupChatResponseReceivedEvent
from ._checkpoint import (
CheckpointStorage,
FileCheckpointStorage,
Expand Down Expand Up @@ -55,37 +56,33 @@
)
from ._function_executor import FunctionExecutor, executor
from ._group_chat import (
DEFAULT_MANAGER_INSTRUCTIONS,
DEFAULT_MANAGER_STRUCTURED_OUTPUT_PROMPT,
AgentBasedGroupChatOrchestrator,
GroupChatBuilder,
GroupChatDirective,
GroupChatStateSnapshot,
ManagerDirectiveModel,
ManagerSelectionRequest,
ManagerSelectionResponse,
GroupChatState,
)
from ._handoff import HandoffBuilder, HandoffUserInputRequest
from ._magentic import (
MAGENTIC_EVENT_TYPE_AGENT_DELTA,
MAGENTIC_EVENT_TYPE_ORCHESTRATOR,
ORCH_MSG_KIND_INSTRUCTION,
ORCH_MSG_KIND_NOTICE,
ORCH_MSG_KIND_TASK_LEDGER,
ORCH_MSG_KIND_USER_TASK,
MagenticBuilder,
MagenticContext,
MagenticHumanInputRequest,
MagenticHumanInterventionDecision,
MagenticHumanInterventionKind,
MagenticHumanInterventionReply,
MagenticHumanInterventionRequest,
MagenticManagerBase,
MagenticStallInterventionDecision,
MagenticStallInterventionReply,
MagenticStallInterventionRequest,
StandardMagenticManager,
)
from ._orchestration_request_info import AgentInputRequest, AgentResponseReviewRequest, RequestInfoInterceptor
from ._handoff import HandoffBuilder

# from ._magentic import (
# MAGENTIC_EVENT_TYPE_AGENT_DELTA,
# MAGENTIC_EVENT_TYPE_ORCHESTRATOR,
# ORCH_MSG_KIND_INSTRUCTION,
# ORCH_MSG_KIND_NOTICE,
# ORCH_MSG_KIND_TASK_LEDGER,
# ORCH_MSG_KIND_USER_TASK,
# MagenticBuilder,
# MagenticContext,
# MagenticHumanInputRequest,
# MagenticHumanInterventionDecision,
# MagenticHumanInterventionKind,
# MagenticHumanInterventionReply,
# MagenticHumanInterventionRequest,
# MagenticManagerBase,
# MagenticStallInterventionDecision,
# MagenticStallInterventionReply,
# MagenticStallInterventionRequest,
# StandardMagenticManager,
# )
from ._orchestration_request_info import AgentRequestInfoResponse
from ._orchestration_state import OrchestrationState
from ._request_info_mixin import response_handler
from ._runner import Runner
Expand All @@ -111,20 +108,13 @@
from ._workflow_executor import SubWorkflowRequestMessage, SubWorkflowResponseMessage, WorkflowExecutor

__all__ = [
"DEFAULT_MANAGER_INSTRUCTIONS",
"DEFAULT_MANAGER_STRUCTURED_OUTPUT_PROMPT",
"DEFAULT_MAX_ITERATIONS",
"MAGENTIC_EVENT_TYPE_AGENT_DELTA",
"MAGENTIC_EVENT_TYPE_ORCHESTRATOR",
"ORCH_MSG_KIND_INSTRUCTION",
"ORCH_MSG_KIND_NOTICE",
"ORCH_MSG_KIND_TASK_LEDGER",
"ORCH_MSG_KIND_USER_TASK",
"AgentBasedGroupChatOrchestrator",
"AgentExecutor",
"AgentExecutorRequest",
"AgentExecutorResponse",
"AgentInputRequest",
"AgentResponseReviewRequest",
"AgentRequestInfoResponse",
Comment thread
TaoChenOSU marked this conversation as resolved.
"AgentRequestInfoResponse",
"AgentRunEvent",
"AgentRunUpdateEvent",
"Case",
Expand All @@ -144,36 +134,36 @@
"FunctionExecutor",
"GraphConnectivityError",
"GroupChatBuilder",
"GroupChatDirective",
"GroupChatStateSnapshot",
"GroupChatRequestSentEvent",
"GroupChatResponseReceivedEvent",
"GroupChatState",
"HandoffBuilder",
"HandoffBuilder",
"HandoffUserInputRequest",
"InMemoryCheckpointStorage",
"InProcRunnerContext",
"MagenticBuilder",
"MagenticContext",
"MagenticHumanInputRequest",
"MagenticHumanInterventionDecision",
"MagenticHumanInterventionKind",
"MagenticHumanInterventionReply",
"MagenticHumanInterventionRequest",
"MagenticManagerBase",
"MagenticStallInterventionDecision",
"MagenticStallInterventionReply",
"MagenticStallInterventionRequest",
"ManagerDirectiveModel",
"ManagerSelectionRequest",
"ManagerSelectionResponse",
# "MagenticBuilder",
# "MagenticContext",
# "MagenticHumanInputRequest",
# "MagenticHumanInterventionDecision",
# "MagenticHumanInterventionKind",
# "MagenticHumanInterventionReply",
# "MagenticHumanInterventionRequest",
# "MagenticManagerBase",
# "MagenticStallInterventionDecision",
# "MagenticStallInterventionReply",
# "MagenticStallInterventionRequest",
# "ManagerDirectiveModel",
# "ManagerSelectionRequest",
# "ManagerSelectionResponse",
"Message",
"OrchestrationState",
"RequestInfoEvent",
"RequestInfoInterceptor",
"Runner",
"RunnerContext",
"SequentialBuilder",
"SharedState",
"SingleEdgeGroup",
"StandardMagenticManager",
# "StandardMagenticManager",
"SubWorkflowRequestMessage",
"SubWorkflowResponseMessage",
"SuperStepCompletedEvent",
Expand Down
Loading
Loading