Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 3bea1c3d2b |
@@ -0,0 +1,101 @@
|
||||
---
|
||||
name: branching-agent-pattern
|
||||
version: 1.0.0
|
||||
description: Define and execute AI agent workflows using CSV-based declarative definitions
|
||||
with configurable branching logic
|
||||
inputs:
|
||||
- 'CSV workflow files defining agent graphs with columns: graph_name, node_name, agent_type,
|
||||
next_node, on_failure, prompt, input_fields, output_field'
|
||||
- LLM provider configuration (OpenAI, Anthropic, Google) in agentmap_config.yaml
|
||||
- Storage backend configuration in agentmap_config_storage.yaml
|
||||
steps:
|
||||
- Define workflow graph in CSV with nodes representing agent steps and their connections
|
||||
(next_node, on_failure)
|
||||
- Configure BranchingAgent with customizable success/failure values and fallback fields
|
||||
in the context dictionary
|
||||
- Initialize the agent runtime with ensure_initialized() and configure execution tracking
|
||||
and state adapter services
|
||||
- Execute the workflow using agentmap run with appropriate inputs and monitor the
|
||||
execution trace
|
||||
outputs:
|
||||
- Executed workflow with results stored in the specified output_field
|
||||
- Detailed execution trace showing success/failure decisions at each branching point
|
||||
- Updated workflow state persisted in the configured storage backend
|
||||
tags: []
|
||||
metadata:
|
||||
source_repo: https://github.com/jwwelbor/AgentMap.git
|
||||
extracted_at: ''
|
||||
confidence: 0.95
|
||||
---
|
||||
|
||||
# branching-agent-pattern
|
||||
|
||||
Define and execute AI agent workflows using CSV-based declarative definitions with configurable branching logic
|
||||
|
||||
## Setup
|
||||
|
||||
**Dependencies:**
|
||||
|
||||
```text
|
||||
pip install langgraph>=1.0.0 langchain-core>=0.3.0 pyyaml>=6.0.0 fastapi>=0.111.0 uvicorn>=0.34.3
|
||||
```
|
||||
|
||||
**Setup steps:**
|
||||
|
||||
1. Install AgentMap: pip install agentmap[all]
|
||||
1. Configure llm providers in agentmap_config.yaml (OpenAI, Anthropic, Google models)
|
||||
1. Create CSV workflow files with graph definitions
|
||||
1. Initialize runtime with ensure_initialized()
|
||||
1. Run workflow with agentmap run <csv_file> --pretty
|
||||
|
||||
## Key Files
|
||||
|
||||
- `agentmap_config.yaml - Main configuration with LLM and storage settings`
|
||||
- `agentmap_config_storage.yaml - Storage backend configuration`
|
||||
- `hello_world.csv - Sample workflow demonstrating basic agent chain`
|
||||
- `examples/host_integration/custom_agents.py - Custom agent implementations with host service integration`
|
||||
|
||||
## Steps
|
||||
|
||||
1. Define workflow graph in CSV with nodes representing agent steps and their connections (next_node, on_failure)
|
||||
2. Configure BranchingAgent with customizable success/failure values and fallback fields in the context dictionary
|
||||
3. Initialize the agent runtime with ensure_initialized() and configure execution tracking and state adapter services
|
||||
4. Execute the workflow using agentmap run with appropriate inputs and monitor the execution trace
|
||||
|
||||
## Implementation Details
|
||||
|
||||
```python
|
||||
CSV format: graph_name,node_name,agent_type,next_node,on_failure,prompt,input_fields,output_field
|
||||
```
|
||||
|
||||
```python
|
||||
BranchingAgent context example: {'input_fields': ['success'], 'output_field': 'result', 'success_values': ['PASSED', 'COMPLETED']}
|
||||
```
|
||||
|
||||
```python
|
||||
Execution command: agentmap run hello_world.csv --pretty
|
||||
```
|
||||
|
||||
## Inputs
|
||||
|
||||
- CSV workflow files defining agent graphs with columns: graph_name, node_name, agent_type, next_node, on_failure, prompt, input_fields, output_field
|
||||
- LLM provider configuration (OpenAI, Anthropic, Google) in agentmap_config.yaml
|
||||
- Storage backend configuration in agentmap_config_storage.yaml
|
||||
|
||||
## Outputs
|
||||
|
||||
- Executed workflow with results stored in the specified output_field
|
||||
- Detailed execution trace showing success/failure decisions at each branching point
|
||||
- Updated workflow state persisted in the configured storage backend
|
||||
|
||||
## Failure Modes
|
||||
|
||||
- Invalid CSV format causing parsing errors during workflow loading
|
||||
- Missing or misconfigured LLM provider settings leading to execution failures
|
||||
- Storage backend unavailable or misconfigured preventing workflow persistence
|
||||
- Agent execution timeout due to long-running operations or infinite loops
|
||||
|
||||
## Source
|
||||
|
||||
Extracted from: [https://github.com/jwwelbor/AgentMap.git](https://github.com/jwwelbor/AgentMap.git)
|
||||
Confidence: 0.95
|
||||
@@ -0,0 +1,6 @@
|
||||
# Commands: branching-agent-pattern
|
||||
|
||||
## Available Commands
|
||||
|
||||
- `/skill branching-agent-pattern` — Load this skill
|
||||
- `/run branching-agent-pattern` — Execute workflow
|
||||
@@ -0,0 +1,10 @@
|
||||
# Examples: branching-agent-pattern
|
||||
|
||||
## Usage Example
|
||||
|
||||
```python
|
||||
# How to use this skill
|
||||
# Inputs: CSV workflow files defining agent graphs with columns: graph_name, node_name, agent_type, next_node, on_failure, prompt, input_fields, output_field, LLM provider configuration (OpenAI, Anthropic, Google) in agentmap_config.yaml, Storage backend configuration in agentmap_config_storage.yaml
|
||||
# Process: Define workflow graph in CSV with nodes representing agent steps and their connections (next_node, on_failure) → Configure BranchingAgent with customizable success/failure values and fallback fields in the context dictionary → Initialize the agent runtime with ensure_initialized() and configure execution tracking and state adapter services
|
||||
# Outputs: Executed workflow with results stored in the specified output_field, Detailed execution trace showing success/failure decisions at each branching point, Updated workflow state persisted in the configured storage backend
|
||||
```
|
||||
@@ -0,0 +1,31 @@
|
||||
{
|
||||
"name": "branching-agent-pattern",
|
||||
"version": "1.0.0",
|
||||
"goal": "Define and execute AI agent workflows using CSV-based declarative definitions with configurable branching logic",
|
||||
"inputs": [
|
||||
"CSV workflow files defining agent graphs with columns: graph_name, node_name, agent_type, next_node, on_failure, prompt, input_fields, output_field",
|
||||
"LLM provider configuration (OpenAI, Anthropic, Google) in agentmap_config.yaml",
|
||||
"Storage backend configuration in agentmap_config_storage.yaml"
|
||||
],
|
||||
"steps": [
|
||||
"Define workflow graph in CSV with nodes representing agent steps and their connections (next_node, on_failure)",
|
||||
"Configure BranchingAgent with customizable success/failure values and fallback fields in the context dictionary",
|
||||
"Initialize the agent runtime with ensure_initialized() and configure execution tracking and state adapter services",
|
||||
"Execute the workflow using agentmap run with appropriate inputs and monitor the execution trace"
|
||||
],
|
||||
"outputs": [
|
||||
"Executed workflow with results stored in the specified output_field",
|
||||
"Detailed execution trace showing success/failure decisions at each branching point",
|
||||
"Updated workflow state persisted in the configured storage backend"
|
||||
],
|
||||
"failure_modes": [
|
||||
"Invalid CSV format causing parsing errors during workflow loading",
|
||||
"Missing or misconfigured LLM provider settings leading to execution failures",
|
||||
"Storage backend unavailable or misconfigured preventing workflow persistence",
|
||||
"Agent execution timeout due to long-running operations or infinite loops"
|
||||
],
|
||||
"confidence": 0.95,
|
||||
"explanation": "The BranchingAgent pattern provides a reusable framework for creating conditional AI workflows. The CSV-based workflow definition allows defining complex agent graphs declaratively, while the BranchingAgent handles dynamic branching based on success/failure conditions with customizable value sets. This pattern can be adapted to various use cases including task routing, error handling, and conditional execution paths across different domains.",
|
||||
"source_repo": "https://github.com/jwwelbor/AgentMap.git",
|
||||
"score": 1.0
|
||||
}
|
||||
@@ -1,4 +1,4 @@
|
||||
# Tests: graph-based-node-workflow
|
||||
# Tests: branching-agent-pattern
|
||||
|
||||
## Test Checklist
|
||||
|
||||
@@ -1,100 +0,0 @@
|
||||
---
|
||||
name: graph-based-node-workflow
|
||||
version: 1.0.0
|
||||
description: Create and execute typed node graphs for AI/robotics workflows by defining
|
||||
nodes with inputs/outputs and connecting them with edges, then cooking the graph
|
||||
to run the workflow.
|
||||
inputs:
|
||||
- bn.Graph() - the graph container for the workflow
|
||||
- Node definitions (Literal, Text, LLMAgent, Concat, Output, etc.) with specified
|
||||
inputs and outputs
|
||||
- Edge connections mapping from_port to to_port between nodes
|
||||
steps:
|
||||
- 'Step 1: Initialize a bn.Graph() instance to serve as the workflow container'
|
||||
- 'Step 2: Define individual nodes with their required inputs and outputs (e.g., Literal
|
||||
for data, LLMAgent for inference, Concat for combining, Output for final results)'
|
||||
- 'Step 3: Create edges connecting nodes by specifying source from_port and destination
|
||||
to_port for each data flow'
|
||||
- 'Step 4: Execute the graph by calling g.cook() to process the defined workflow and
|
||||
produce results'
|
||||
outputs:
|
||||
- Executed workflow results stored in the graph's output nodes
|
||||
- Cooked graph ready for inspection, replay, or deployment
|
||||
- Potential error states if node dependencies are missing or ports don't match
|
||||
tags: []
|
||||
metadata:
|
||||
source_repo: https://github.com/temiroff/Blacknode.git
|
||||
extracted_at: ''
|
||||
confidence: 0.95
|
||||
---
|
||||
|
||||
# graph-based-node-workflow
|
||||
|
||||
Create and execute typed node graphs for AI/robotics workflows by defining nodes with inputs/outputs and connecting them with edges, then cooking the graph to run the workflow.
|
||||
|
||||
## Setup
|
||||
|
||||
**Dependencies:**
|
||||
|
||||
```text
|
||||
pip install blacknode (core Python package) anthropic, openai, docker, petgraph (dependencies) Rust extensions in blacknode-core, blacknode-runtime (optional)
|
||||
```
|
||||
|
||||
**Setup steps:**
|
||||
|
||||
1. Install blacknode with Python 3.11+ and required dependencies
|
||||
1. Clone repository and navigate to project directory
|
||||
1. Run examples/converted_text_pipeline.py to see basic graph execution
|
||||
1. Modify node definitions and edges to create custom workflows
|
||||
|
||||
## Key Files
|
||||
|
||||
- `examples/converted_text_pipeline.py - basic pipeline pattern`
|
||||
- `examples/hello_agent.py - LLM agent workflow pattern`
|
||||
- `examples/research_pipeline.py - multi-node research workflow`
|
||||
- `blacknode.py - main CLI entry point`
|
||||
|
||||
## Steps
|
||||
|
||||
1. Step 1: Initialize a bn.Graph() instance to serve as the workflow container
|
||||
2. Step 2: Define individual nodes with their required inputs and outputs (e.g., Literal for data, LLMAgent for inference, Concat for combining, Output for final results)
|
||||
3. Step 3: Create edges connecting nodes by specifying source from_port and destination to_port for each data flow
|
||||
4. Step 4: Execute the graph by calling g.cook() to process the defined workflow and produce results
|
||||
|
||||
## Implementation Details
|
||||
|
||||
```python
|
||||
g = bn.Graph()
|
||||
```
|
||||
|
||||
```python
|
||||
g._edges = [{"from": "model", "from_port": "value", "to": "agent", "to_port": "model"}]
|
||||
```
|
||||
|
||||
```python
|
||||
result = g.cook(output, "value")
|
||||
```
|
||||
|
||||
## Inputs
|
||||
|
||||
- bn.Graph() - the graph container for the workflow
|
||||
- Node definitions (Literal, Text, LLMAgent, Concat, Output, etc.) with specified inputs and outputs
|
||||
- Edge connections mapping from_port to to_port between nodes
|
||||
|
||||
## Outputs
|
||||
|
||||
- Executed workflow results stored in the graph's output nodes
|
||||
- Cooked graph ready for inspection, replay, or deployment
|
||||
- Potential error states if node dependencies are missing or ports don't match
|
||||
|
||||
## Failure Modes
|
||||
|
||||
- Missing node dependencies causing undefined variable errors
|
||||
- Port mismatch in edge connections leading to no data flow
|
||||
- Incomplete graph definition causing cook() to fail
|
||||
- Model API key missing or invalid for LLMAgent nodes
|
||||
|
||||
## Source
|
||||
|
||||
Extracted from: [https://github.com/temiroff/Blacknode.git](https://github.com/temiroff/Blacknode.git)
|
||||
Confidence: 0.95
|
||||
@@ -1,6 +0,0 @@
|
||||
# Commands: graph-based-node-workflow
|
||||
|
||||
## Available Commands
|
||||
|
||||
- `/skill graph-based-node-workflow` — Load this skill
|
||||
- `/run graph-based-node-workflow` — Execute workflow
|
||||
@@ -1,10 +0,0 @@
|
||||
# Examples: graph-based-node-workflow
|
||||
|
||||
## Usage Example
|
||||
|
||||
```python
|
||||
# How to use this skill
|
||||
# Inputs: bn.Graph() - the graph container for the workflow, Node definitions (Literal, Text, LLMAgent, Concat, Output, etc.) with specified inputs and outputs, Edge connections mapping from_port to to_port between nodes
|
||||
# Process: Step 1: Initialize a bn.Graph() instance to serve as the workflow container → Step 2: Define individual nodes with their required inputs and outputs (e.g., Literal for data, LLMAgent for inference, Concat for combining, Output for final results) → Step 3: Create edges connecting nodes by specifying source from_port and destination to_port for each data flow
|
||||
# Outputs: Executed workflow results stored in the graph's output nodes, Cooked graph ready for inspection, replay, or deployment, Potential error states if node dependencies are missing or ports don't match
|
||||
```
|
||||
@@ -1,31 +0,0 @@
|
||||
{
|
||||
"name": "graph-based-node-workflow",
|
||||
"version": "1.0.0",
|
||||
"goal": "Create and execute typed node graphs for AI/robotics workflows by defining nodes with inputs/outputs and connecting them with edges, then cooking the graph to run the workflow.",
|
||||
"inputs": [
|
||||
"bn.Graph() - the graph container for the workflow",
|
||||
"Node definitions (Literal, Text, LLMAgent, Concat, Output, etc.) with specified inputs and outputs",
|
||||
"Edge connections mapping from_port to to_port between nodes"
|
||||
],
|
||||
"steps": [
|
||||
"Step 1: Initialize a bn.Graph() instance to serve as the workflow container",
|
||||
"Step 2: Define individual nodes with their required inputs and outputs (e.g., Literal for data, LLMAgent for inference, Concat for combining, Output for final results)",
|
||||
"Step 3: Create edges connecting nodes by specifying source from_port and destination to_port for each data flow",
|
||||
"Step 4: Execute the graph by calling g.cook() to process the defined workflow and produce results"
|
||||
],
|
||||
"outputs": [
|
||||
"Executed workflow results stored in the graph's output nodes",
|
||||
"Cooked graph ready for inspection, replay, or deployment",
|
||||
"Potential error states if node dependencies are missing or ports don't match"
|
||||
],
|
||||
"failure_modes": [
|
||||
"Missing node dependencies causing undefined variable errors",
|
||||
"Port mismatch in edge connections leading to no data flow",
|
||||
"Incomplete graph definition causing cook() to fail",
|
||||
"Model API key missing or invalid for LLMAgent nodes"
|
||||
],
|
||||
"confidence": 0.95,
|
||||
"explanation": "This workflow pattern is reusable across different AI/robotics applications because it provides a standardized way to compose complex pipelines from typed nodes. The pattern can be adapted to various use cases like research pipelines, agent workflows, or robotics control graphs by simply adding/removing nodes and edges while maintaining the same graph-cooking execution model.",
|
||||
"source_repo": "https://github.com/temiroff/Blacknode.git",
|
||||
"score": 1.0
|
||||
}
|
||||
Reference in New Issue
Block a user