Skip to content

Commit e4d33ac

Browse files
ivanmilevtuesivanmilevtues
committed
Added new workflow integration
1 parent c71e1d7 commit e4d33ac

23 files changed

Lines changed: 1773 additions & 847 deletions

‎.codeboarding/Agent_Core_LLM_Integration.json‎

Lines changed: 141 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,141 @@
1+
{
2+
"description": "This subsystem defines the fundamental interface and capabilities of an AI agent, encapsulating interactions with Large Language Models (LLMs), external tools, prompts, and resources. It provides a consistent and extensible model for agent behavior and offers a standardized, augmented interface for interacting with various LLM providers.",
3+
"components": [
4+
{
5+
"name": "Agent Core",
6+
"description": "This is the foundational interface for all AI agents within the `mcp-agent` framework. It defines the core capabilities and interaction points of an agent, serving as the base for more specialized agent types. It encapsulates the agent's logic, its interaction with LLMs, and its ability to utilize external tools and resources.",
7+
"referenced_source_code": [
8+
{
9+
"qualified_name": "mcp_agent.agents.agent.Agent",
10+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/agents/agent.py",
11+
"reference_start_line": 56,
12+
"reference_end_line": 934
13+
}
14+
]
15+
},
16+
{
17+
"name": "Augmented LLM Interface",
18+
"description": "This abstract component provides a unified and enhanced interface for interacting with different LLM providers. It abstracts away the vendor-specific details of LLM APIs, allowing the rest of the framework to interact with LLMs in a consistent manner, regardless of the underlying provider. It supports various LLM operations, including completion and structured completion requests.",
19+
"referenced_source_code": [
20+
{
21+
"qualified_name": "mcp_agent.workflows.llm.augmented_llm.AugmentedLLM",
22+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/workflows/llm/augmented_llm.py",
23+
"reference_start_line": 218,
24+
"reference_end_line": 668
25+
}
26+
]
27+
},
28+
{
29+
"name": "LLM Selector",
30+
"description": "This component is responsible for intelligently selecting the most suitable LLM model for a given task. It considers various criteria such as cost, latency, and performance benchmarks to make informed decisions, optimizing resource utilization and response quality.",
31+
"referenced_source_code": [
32+
{
33+
"qualified_name": "mcp_agent.workflows.llm.llm_selector.ModelSelector",
34+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/workflows/llm/llm_selector.py",
35+
"reference_start_line": 96,
36+
"reference_end_line": 413
37+
}
38+
]
39+
},
40+
{
41+
"name": "LLM Provider Implementations",
42+
"description": "These are concrete implementations of the `Augmented LLM Interface`, providing the actual connectivity and interaction logic for specific LLM providers (e.g., Anthropic, Azure, Bedrock, Google, OpenAI, Ollama). Each implementation handles the nuances of its respective LLM API and translates requests and responses to and from the framework's internal format.",
43+
"referenced_source_code": [
44+
{
45+
"qualified_name": "mcp_agent.workflows.llm.augmented_llm_anthropic.AnthropicAugmentedLLM",
46+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/workflows/llm/augmented_llm_anthropic.py",
47+
"reference_start_line": 110,
48+
"reference_end_line": 722
49+
},
50+
{
51+
"qualified_name": "mcp_agent.workflows.llm.augmented_llm_azure.AzureAugmentedLLM",
52+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/workflows/llm/augmented_llm_azure.py",
53+
"reference_start_line": 82,
54+
"reference_end_line": 491
55+
},
56+
{
57+
"qualified_name": "mcp_agent.workflows.llm.augmented_llm_bedrock.BedrockAugmentedLLM",
58+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/workflows/llm/augmented_llm_bedrock.py",
59+
"reference_start_line": 48,
60+
"reference_end_line": 349
61+
},
62+
{
63+
"qualified_name": "mcp_agent.workflows.llm.augmented_llm_google.GoogleAugmentedLLM",
64+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/workflows/llm/augmented_llm_google.py",
65+
"reference_start_line": 34,
66+
"reference_end_line": 319
67+
},
68+
{
69+
"qualified_name": "mcp_agent.workflows.llm.augmented_llm_ollama.OllamaAugmentedLLM",
70+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/workflows/llm/augmented_llm_ollama.py",
71+
"reference_start_line": 16,
72+
"reference_end_line": 78
73+
},
74+
{
75+
"qualified_name": "mcp_agent.workflows.llm.augmented_llm_openai.OpenAIAugmentedLLM",
76+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/workflows/llm/augmented_llm_openai.py",
77+
"reference_start_line": 80,
78+
"reference_end_line": 845
79+
}
80+
]
81+
},
82+
{
83+
"name": "Provider to MCP Converters",
84+
"description": "These utility classes are crucial for ensuring data consistency and interoperability across different LLM providers. They are responsible for converting provider-specific data structures (e.g., Anthropic's messages, OpenAI's chat completions) into the framework's standardized Model Context Protocol (MCP) types.",
85+
"referenced_source_code": [
86+
{
87+
"qualified_name": "mcp_agent.workflows.llm.augmented_llm_anthropic.AnthropicMCPTypeConverter",
88+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/workflows/llm/augmented_llm_anthropic.py",
89+
"reference_start_line": 777,
90+
"reference_end_line": 886
91+
},
92+
{
93+
"qualified_name": "mcp_agent.workflows.llm.augmented_llm_azure.MCPAzureTypeConverter",
94+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/workflows/llm/augmented_llm_azure.py",
95+
"reference_start_line": 524,
96+
"reference_end_line": 614
97+
},
98+
{
99+
"qualified_name": "mcp_agent.workflows.llm.augmented_llm_bedrock.BedrockMCPTypeConverter",
100+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/workflows/llm/augmented_llm_bedrock.py",
101+
"reference_start_line": 437,
102+
"reference_end_line": 499
103+
},
104+
{
105+
"qualified_name": "mcp_agent.workflows.llm.augmented_llm_google.GoogleMCPTypeConverter",
106+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/workflows/llm/augmented_llm_google.py",
107+
"reference_start_line": 403,
108+
"reference_end_line": 518
109+
},
110+
{
111+
"qualified_name": "mcp_agent.workflows.llm.augmented_llm_openai.MCPOpenAITypeConverter",
112+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/workflows/llm/augmented_llm_openai.py",
113+
"reference_start_line": 949,
114+
"reference_end_line": 1055
115+
}
116+
]
117+
}
118+
],
119+
"components_relations": [
120+
{
121+
"relation": "uses",
122+
"src_name": "Agent Core",
123+
"dst_name": "Augmented LLM Interface"
124+
},
125+
{
126+
"relation": "uses",
127+
"src_name": "Augmented LLM Interface",
128+
"dst_name": "LLM Selector"
129+
},
130+
{
131+
"relation": "implements",
132+
"src_name": "LLM Provider Implementations",
133+
"dst_name": "Augmented LLM Interface"
134+
},
135+
{
136+
"relation": "uses",
137+
"src_name": "LLM Provider Implementations",
138+
"dst_name": "Provider to MCP Converters"
139+
}
140+
]
141+
}

‎.codeboarding/Agent_Execution_Workflow_Engine.json‎

Lines changed: 138 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,138 @@
1+
{
2+
"description": "Abstract Components Overview",
3+
"components": [
4+
{
5+
"name": "Execution Engine",
6+
"description": "This is the core component responsible for the actual execution of tasks and activities. It provides an abstract interface (Executor) for running executable units, with concrete implementations like AsyncioExecutor for immediate asynchronous execution and TemporalExecutor for durable, long-running workflows. It manages the runtime environment for tasks and orchestrates their execution flow.",
7+
"referenced_source_code": [
8+
{
9+
"qualified_name": "mcp_agent/executor/executor.py",
10+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/executor/executor.py",
11+
"reference_start_line": 0,
12+
"reference_end_line": 0
13+
},
14+
{
15+
"qualified_name": "mcp_agent/executor/temporal/TemporalExecutor.py",
16+
"reference_file": "mcp_agent/executor/temporal/TemporalExecutor.py",
17+
"reference_start_line": 0,
18+
"reference_end_line": 0
19+
}
20+
]
21+
},
22+
{
23+
"name": "Workflow Management",
24+
"description": "This component defines the structure, state, and lifecycle of complex, multi-step processes. It provides the Workflow abstraction, allowing for the definition of sequences of tasks and decision points. InteractiveWorkflow specifically handles scenarios requiring human input or external interaction, enabling robust and adaptable agent workflows.",
25+
"referenced_source_code": [
26+
{
27+
"qualified_name": "mcp_agent/executor/workflow.py",
28+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/executor/workflow.py",
29+
"reference_start_line": 0,
30+
"reference_end_line": 0
31+
},
32+
{
33+
"qualified_name": "mcp_agent/executor/temporal/interactive_workflow.py",
34+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/executor/temporal/interactive_workflow.py",
35+
"reference_start_line": 0,
36+
"reference_end_line": 0
37+
}
38+
]
39+
},
40+
{
41+
"name": "Task/Activity Registry",
42+
"description": "A centralized repository that allows for the registration and dynamic retrieval of executable tasks or \"activities.\" This component is crucial for the Execution Engine to discover and invoke the specific functions or methods that constitute an agent's capabilities or a workflow's steps. It promotes modularity by decoupling task definition from task execution.",
43+
"referenced_source_code": [
44+
{
45+
"qualified_name": "mcp_agent/executor/task_registry.py",
46+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/executor/task_registry.py",
47+
"reference_start_line": 0,
48+
"reference_end_line": 0
49+
}
50+
]
51+
},
52+
{
53+
"name": "Signal Handling",
54+
"description": "This component provides a robust mechanism for inter-component communication and handling external events, including human input. It enables workflows and tasks to asynchronously wait for, send, and receive signals, which is vital for interactive processes, state transitions, and coordination within the agent system. It includes a registry for managing various signal handlers.",
55+
"referenced_source_code": [
56+
{
57+
"qualified_name": "mcp_agent/executor/signal_registry.py",
58+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/executor/signal_registry.py",
59+
"reference_start_line": 0,
60+
"reference_end_line": 0
61+
},
62+
{
63+
"qualified_name": "mcp_agent/executor/workflow_signal.py",
64+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/executor/workflow_signal.py",
65+
"reference_start_line": 0,
66+
"reference_end_line": 0
67+
}
68+
]
69+
},
70+
{
71+
"name": "Decorator Registry",
72+
"description": "This component serves as a dedicated registry for managing decorators that can be applied to tasks or workflows. It facilitates the application of cross-cutting concerns (e.g., logging, error handling, retry mechanisms, authentication) in a declarative manner, enhancing the extensibility and maintainability of the executable units without modifying their core logic.",
73+
"referenced_source_code": [
74+
{
75+
"qualified_name": "mcp_agent/executor/decorator_registry.py",
76+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/executor/decorator_registry.py",
77+
"reference_start_line": 0,
78+
"reference_end_line": 0
79+
}
80+
]
81+
},
82+
{
83+
"name": "Workflow Registry",
84+
"description": "This component is responsible for registering and providing access to defined workflow blueprints. It allows the system to dynamically discover and instantiate workflows based on their unique identifiers, supporting different underlying storage or persistence mechanisms (e.g., in-memory for transient workflows, Temporal for durable workflows).",
85+
"referenced_source_code": [
86+
{
87+
"qualified_name": "mcp_agent/executor/workflow_registry.py",
88+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/executor/workflow_registry.py",
89+
"reference_start_line": 0,
90+
"reference_end_line": 0
91+
},
92+
{
93+
"qualified_name": "mcp_agent/executor/temporal/workflow_registry.py",
94+
"reference_file": "/home/ivan/StartUp/CodeBoarding/repos/mcp-agent/src/mcp_agent/executor/temporal/workflow_registry.py",
95+
"reference_start_line": 0,
96+
"reference_end_line": 0
97+
}
98+
]
99+
}
100+
],
101+
"components_relations": [
102+
{
103+
"relation": "uses",
104+
"src_name": "Execution Engine",
105+
"dst_name": "Task/Activity Registry"
106+
},
107+
{
108+
"relation": "uses",
109+
"src_name": "Execution Engine",
110+
"dst_name": "Workflow Management"
111+
},
112+
{
113+
"relation": "uses",
114+
"src_name": "Execution Engine",
115+
"dst_name": "Signal Handling"
116+
},
117+
{
118+
"relation": "uses",
119+
"src_name": "Execution Engine",
120+
"dst_name": "Workflow Registry"
121+
},
122+
{
123+
"relation": "interacts with",
124+
"src_name": "Workflow Management",
125+
"dst_name": "Signal Handling"
126+
},
127+
{
128+
"relation": "registers with",
129+
"src_name": "Workflow Management",
130+
"dst_name": "Workflow Registry"
131+
},
132+
{
133+
"relation": "potentially uses",
134+
"src_name": "Execution Engine",
135+
"dst_name": "Decorator Registry"
136+
}
137+
]
138+
}

0 commit comments

Comments
 (0)