Go Version License

A lightweight, high-performance workflow engine designed for seamless integration with business code. Features storage-separated architecture, DAG (Directed Acyclic Graph) workflow orchestration, and flexible node execution with dependency management.

• Lightweight & Fast: Minimal dependencies, optimized for performance
• DAG Workflows: Support for complex directed acyclic graph orchestration
• Storage Agnostic: Pluggable storage backends with clean interface separation
• Scheduled Execution: Built-in Cron scheduler for automated workflows
• Type Safe: Strong typing with comprehensive error handling
• Extensible: Plugin-based node executors for custom business logic
• Concurrent: Intelligent parallel execution with dependency resolution
• Production Ready: Comprehensive logging and monitoring capabilities

go get github.com/ComingCL/go-workflow

• WorkflowEngine: Executes workflows with DAG parsing and node orchestration
• WorkflowDAG: Manages directed acyclic graphs with topological sorting
• WorkflowController: Handles workflow lifecycle and scheduling
• CronScheduler: Provides cron-based automated execution
• WorkflowRepository: Abstraction layer for data persistence

import "github.com/ComingCL/go-workflow/workflow"
// Create workflow
wf := &workflow.Workflow{
 Metadata: workflow.Metadata{
 Name: "my-workflow",
 UID: "wf-001",
 },
}
// Initialize engine
engine, err := workflow.NewEngine(ctx, wf, controller, repository)
if err != nil {
 log.Fatal(err)
}
// Add nodes with dependencies
engine.AddWorkflowNode("build", "Build", NodeTypeBuild, buildData)
engine.AddWorkflowNode("test", "Test", NodeTypeTest, testData)
engine.AddWorkflowNode("deploy", "Deploy", NodeTypeDeploy, deployData)
// Define execution order
engine.AddWorkflowDependency("build", "test")
engine.AddWorkflowDependency("test", "deploy")
// Execute
err = engine.ExecuteWorkflow(ctx)

// Create scheduled workflow
wf := &workflow.Workflow{
 Spec: workflow.Spec{
 Schedule: "0 2 * * *", // Daily at 2 AM
 },
}
// Add to scheduler
controller.AddScheduledWorkflow(ctx, wf)
controller.Run(ctx)

Comprehensive examples are available in the examples/ directory:

• Basic Usage - Complete workflow setup and execution
• Scheduled Workflows - Cron-based automation
• DAG Management - Advanced graph operations

Each example includes full source code and can be run independently:

cd examples/basic && go run main.go
cd examples/scheduled && go run main.go
cd examples/dag && go run main.go

type CustomExecutor struct{}
func (e *CustomExecutor) ExecuteWorkflowNode(ctx context.Context, data workflow.NodeData) workflow.Result {
 // Your business logic here
 return workflow.Result{
 Err: nil,
 Message: "Success",
 }
}
// Register executor
engine.RegisterFunc(NodeTypeBuild, &CustomExecutor{})

type MyRepository struct{}
func (r *MyRepository) GetWorkflowInstance(ctx context.Context, uid string) (*workflow.Workflow, error) {
 // Implement your storage logic
}
func (r *MyRepository) UpdateWorkflowInstance(ctx context.Context, wf *workflow.Workflow) error {
 // Implement your storage logic
}
// Set repository
controller.SetRepository(&MyRepository{})

• NodePending - Awaiting execution
• NodeRunning - Currently executing
• NodeSucceeded - Completed successfully
• NodeFailed - Execution failed
• NodeSkipped - Conditionally skipped

# Run all tests
go test ./...
# Run with coverage
go test -cover ./...
# Run specific package tests
go test ./workflow -v

Perfect for monolithic applications where workflows are tightly coupled with business logic.

Ideal for distributed systems with workflow orchestration as a separate service.

Suitable for reactive systems with message queue triggers.

• Go 1.21+ - Core runtime requirement
• github.com/ComingCL/go-stl - Graph data structures
• github.com/robfig/cron/v3 - Cron scheduling
• k8s.io/apimachinery - Metadata handling
• k8s.io/klog/v2 - Structured logging

• Web-based workflow designer
• REST API endpoints
• Prometheus metrics integration
• Distributed execution support
• Conditional workflow branches
• Workflow templates and inheritance

Contributions are welcome! Please follow these guidelines:

1. Fork the repository
2. Create a feature branch (git checkout -b feature/amazing-feature)
3. Commit your changes (git commit -m 'Add amazing feature')
4. Push to the branch (git push origin feature/amazing-feature)
5. Open a Pull Request

• Follow Go coding standards and best practices
• Add comprehensive tests for new features
• Update documentation for API changes
• Ensure all tests pass before submitting

This project is licensed under the MIT License - see the LICENSE file for details.

• robfig/cron - Reliable cron scheduling
• Kubernetes - API design patterns and best practices
• Go STL - Efficient graph algorithms

• Issues: GitHub Issues
• Discussions: GitHub Discussions
• Documentation: Project Wiki

Go-Workflow - Simplifying workflow orchestration for Go applications 🚀