mirror of
https://github.com/johndoe6345789/metabuilder.git
synced 2026-04-25 06:14:59 +00:00
johndoe6345789
3d6ae4cbf7
Add full Python workflow execution engine with: Core Executor: - engine.py: WorkflowEngine for running n8n configs - n8n_executor.py: N8N-style workflow execution with connections - node_executor.py: Individual node execution with plugin dispatch - loop_executor.py: Loop node execution with iteration control - execution_order.py: Topological sort for node ordering Schema & Validation: - n8n_schema.py: N8N workflow schema types and validation - n8n_converter.py: Legacy to n8n schema conversion Plugin System: - plugin_loader.py: Dynamic plugin loading - plugin_registry.py: Plugin discovery and registration - plugin_map.json: 116 plugin type mappings Runtime & Context: - runtime.py: Workflow runtime container - input_resolver.py: Binding and coercion resolution - value_helpers.py: Value normalization helpers - workflow_context_builder.py: Runtime context assembly - workflow_config_loader.py: Configuration loading - workflow_engine_builder.py: Engine assembly with dependencies Utilities: - tool_calls_handler.py: LLM tool call handling - tool_runner.py: Tool execution with logging - notification_helpers.py: Slack/Discord notifications - workflow_adapter.py: N8N format handling - workflow_graph.py: Node/edge graph for visualization Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
47 lines
1.6 KiB
Python
47 lines
1.6 KiB
Python
"""Workflow engine package.
|
|
|
|
This package provides a declarative workflow engine that executes n8n-style workflows.
|
|
|
|
Core Modules:
|
|
engine.py - Main workflow engine and execution coordinator
|
|
runtime.py - Runtime context and state management
|
|
|
|
Execution:
|
|
n8n_executor.py - N8N workflow format executor
|
|
node_executor.py - Individual node execution
|
|
execution_order.py - Topological sort for node execution order
|
|
loop_executor.py - Loop iteration execution
|
|
|
|
N8N Support:
|
|
n8n_schema.py - N8N workflow schema definitions
|
|
n8n_converter.py - Convert legacy workflows to N8N format
|
|
workflow_adapter.py - Workflow format adapter
|
|
|
|
Plugin System:
|
|
plugin_loader.py - Plugin loading utilities
|
|
plugin_registry.py - Plugin registration and discovery
|
|
plugin_map.json - Plugin name to module path mapping
|
|
plugins/ - Organized workflow plugins by category
|
|
|
|
Utilities:
|
|
input_resolver.py - Input value resolution and variable binding
|
|
value_helpers.py - Value type checking and conversion helpers
|
|
tool_runner.py - Tool execution wrapper
|
|
tool_calls_handler.py - AI tool calls processing
|
|
|
|
Workflow Engine Building:
|
|
workflow_config_loader.py - Load workflow configuration JSON
|
|
workflow_context_builder.py - Build workflow runtime context
|
|
workflow_engine_builder.py - Assemble workflow engine with dependencies
|
|
"""
|
|
|
|
from .workflow_config_loader import load_workflow_config
|
|
from .workflow_context_builder import build_workflow_context
|
|
from .workflow_engine_builder import build_workflow_engine
|
|
|
|
__all__ = [
|
|
"load_workflow_config",
|
|
"build_workflow_context",
|
|
"build_workflow_engine",
|
|
]
|