Skip to content

Python: [BREAKING] Python: Intro group chat and refactor orchestrations. Fix as_agent(). Standardize orchestration start msg types. #1538

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
merged 21 commits into from
Oct 25, 2025
Merged

Python: [BREAKING] Python: Intro group chat and refactor orchestrations. Fix as_agent(). Standardize orchestration start msg types. #1538

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
21 commits
Select commit Hold shift + click to select a range
24bdd29
Intro group chat and refactor magentic. Fix as_agent()
moonbox3 Oct 17, 2025
0bf23fb
Cleanup and improvements
moonbox3 Oct 17, 2025
66754e9
Add as_agent docstring clarification
moonbox3 Oct 17, 2025
37b8d4b
Standardize orchestration messages to use agent-style inputs.
moonbox3 Oct 20, 2025
eda260d
merge main
moonbox3 Oct 21, 2025
86df5aa
Simplify group chat constructs
moonbox3 Oct 21, 2025
567e37d
Further cleanup
moonbox3 Oct 21, 2025
0e41a33
Add sk to af group chat migration sample. Update README.
moonbox3 Oct 21, 2025
169822d
Improvements and simplifications
moonbox3 Oct 22, 2025
6494d1a
Merge main
moonbox3 Oct 22, 2025
aa03e63
consolidating shared orchestration logic
moonbox3 Oct 22, 2025
b324bce
Further clean up
moonbox3 Oct 22, 2025
7f3a16b
Add group chat sample
moonbox3 Oct 22, 2025
e030474
Improve typing
moonbox3 Oct 22, 2025
9660e59
Fix test imports
moonbox3 Oct 22, 2025
e54786a
Fix readme links
moonbox3 Oct 22, 2025
31d1f85
Merge branch 'main' into refactor-to-group-chat
moonbox3 Oct 22, 2025
21c1566
Cleanup per PR Feedback
moonbox3 Oct 24, 2025
8c6020b
Merge branch 'refactor-to-group-chat' of github.com:moonbox3/agent-fr…
moonbox3 Oct 24, 2025
c3c9fb8
Merge branch 'main' into refactor-to-group-chat
moonbox3 Oct 24, 2025
1c6ec78
Merge branch 'main' into refactor-to-group-chat
moonbox3 Oct 24, 2025
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
32 changes: 28 additions & 4 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 @@ -52,13 +52,26 @@
handler,
)
from ._function_executor import FunctionExecutor, executor
from ._group_chat import (
DEFAULT_MANAGER_INSTRUCTIONS,
GroupChatBuilder,
GroupChatDirective,
GroupChatManagerProtocol,
GroupChatOrchestratorExecutor,
GroupChatParticipantNodes,
GroupChatParticipantSpec,
GroupChatRequestMessage,
GroupChatResponseMessage,
GroupChatState,
GroupChatTurn,
GroupChatWiring,
StandardGroupChatManager,
)
from ._magentic import (
MagenticAgentDeltaEvent,
MagenticAgentExecutor,
MagenticAgentMessageEvent,
MagenticBuilder,
MagenticCallbackEvent,
MagenticCallbackMode,
MagenticContext,
MagenticFinalResultEvent,
MagenticManagerBase,
Expand Down Expand Up @@ -103,6 +116,7 @@
from ._workflow_executor import WorkflowExecutor

__all__ = [
"DEFAULT_MANAGER_INSTRUCTIONS",
"DEFAULT_MAX_ITERATIONS",
"AgentExecutor",
"AgentExecutorRequest",
Expand All @@ -126,14 +140,23 @@
"FileCheckpointStorage",
"FunctionExecutor",
"GraphConnectivityError",
"GroupChatBuilder",
"GroupChatDirective",
"GroupChatManagerProtocol",
"GroupChatOrchestratorExecutor",
"GroupChatParticipantNodes",
"GroupChatParticipantSpec",
"GroupChatRequestMessage",
"GroupChatResponseMessage",
"GroupChatState",
"GroupChatTurn",
"GroupChatWiring",
"InMemoryCheckpointStorage",
"InProcRunnerContext",
"MagenticAgentDeltaEvent",
"MagenticAgentExecutor",
"MagenticAgentMessageEvent",
"MagenticBuilder",
"MagenticCallbackEvent",
"MagenticCallbackMode",
"MagenticContext",
"MagenticFinalResultEvent",
"MagenticManagerBase",
Expand All @@ -158,6 +181,7 @@
"SequentialBuilder",
"SharedState",
"SingleEdgeGroup",
"StandardGroupChatManager",
"StandardMagenticManager",
"SwitchCaseEdgeGroup",
"SwitchCaseEdgeGroupCase",
Expand Down
22 changes: 18 additions & 4 deletions python/packages/core/agent_framework/_workflows/__init__.pyi
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -50,13 +50,21 @@ from ._executor import (
handler,
)
from ._function_executor import FunctionExecutor, executor
from ._group_chat import (
GroupChatBuilder,
GroupChatDirective,
GroupChatManagerProtocol,
GroupChatOrchestratorExecutor,
GroupChatRequestMessage,
GroupChatResponseMessage,
GroupChatState,
StandardGroupChatManager,
)
from ._magentic import (
MagenticAgentDeltaEvent,
MagenticAgentExecutor,
MagenticAgentMessageEvent,
MagenticBuilder,
MagenticCallbackEvent,
MagenticCallbackMode,
MagenticContext,
MagenticFinalResultEvent,
MagenticManagerBase,
Expand Down Expand Up @@ -124,14 +132,19 @@ __all__ = [
"FileCheckpointStorage",
"FunctionExecutor",
"GraphConnectivityError",
"GroupChatBuilder",
"GroupChatDirective",
"GroupChatManagerProtocol",
"GroupChatOrchestratorExecutor",
"GroupChatRequestMessage",
"GroupChatResponseMessage",
"GroupChatState",
"InMemoryCheckpointStorage",
"InProcRunnerContext",
"MagenticAgentDeltaEvent",
"MagenticAgentExecutor",
"MagenticAgentMessageEvent",
"MagenticBuilder",
"MagenticCallbackEvent",
"MagenticCallbackMode",
"MagenticContext",
"MagenticFinalResultEvent",
"MagenticManagerBase",
Expand All @@ -156,6 +169,7 @@ __all__ = [
"SequentialBuilder",
"SharedState",
"SingleEdgeGroup",
"StandardGroupChatManager",
"StandardMagenticManager",
"SwitchCaseEdgeGroup",
"SwitchCaseEdgeGroupCase",
Expand Down
8 changes: 1 addition & 7 deletions python/packages/core/agent_framework/_workflows/_executor.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -450,13 +450,7 @@ def to_dict(self) -> dict[str, Any]:

def handler(
func: Callable[[ExecutorT, Any, ContextT], Awaitable[Any]],
) -> (
Callable[[ExecutorT, Any, ContextT], Awaitable[Any]]
| Callable[
[Callable[[ExecutorT, Any, ContextT], Awaitable[Any]]],
Callable[[ExecutorT, Any, ContextT], Awaitable[Any]],
]
):
) -> Callable[[ExecutorT, Any, ContextT], Awaitable[Any]]:
"""Decorator to register a handler for an executor.

Args:
Expand Down
Loading