Argo Workflows

活跃
GitHub Go Apache-2.0

简介

Argo Workflows 是面向 Kubernetes 的开源容器原生工作流引擎,可用于编排 AI Agent 任务与多步骤流水线。

核心特性

  • 容器原生工作流 — 每个 step 都在独立容器中运行,环境隔离且可复现
  • DAG 与步骤编排 — 支持有向无环图、并行分支、循环、退出钩子和重试
  • 多种执行模式 — 包括容器、脚本、Suspend/Resume 和资源模板
  • Argo Events 集成 — 响应外部事件触发工作流(webhook、SQS、Kafka)
  • 内置工件管理 — S3、GCS、MinIO 等后端在 step 之间传递数据
  • 可视化 UI — 实时显示 DAG 状态、日志和执行时间线

适用场景

💡 在 Kubernetes 上编排多阶段 LLM 数据处理与推理流水线
💡 把每个 Agent 任务作为独立容器 step 并行执行并自动重试
💡 触发事件驱动的 Agent 工作流(webhook、SQS、Kafka)
💡 跨 step 传递大量工件(数据集、模型权重、检索结果)
💡 用 Argo UI 实时监控生产环境 Agent 流程的执行状态

优势与不足

优势

  • 活跃维护,近期持续更新
  • 社区热度高(16.9k stars)
  • 开源许可证友好(Apache-2.0)

⚠️ 不足

  • Issue 积压较多(1.3k 个 open issues)

快速开始

# 安装 Argo Workflows 控制器
kubectl create namespace argo
kubectl apply -n argo -f https://github.com/argoproj/argo-workflows/releases/download/v3.6.0/install.yaml
# 提交 hello-world 示例
argo submit -n argo --watch https://raw.githubusercontent.com/argoproj/argo-workflows/main/examples/hello-world.yaml
argo list -n argo

相关项目

Hatchet

7.7k · Go
活跃 A+

Go 编写的持久化工作流与后台任务编排引擎,专为 AI Agent 与 DAG 工作负载设计。

workfloworchestrationdurable-execution +1
  • · 持久化工作流 — 支持暂停/恢复、事件等待和自动故障恢复的容错长时间运行任务
  • · DAG 编排 — 使用有向无环图构建数据管道和复杂工作流
  • · 多语言 SDK — 为 Python、TypeScript、Go 和 Ruby 应用提供一等支持

Temporal

22.3k · Go
活跃 A

Temporal 是一个分布式可靠的持久执行平台,通过自动重试和状态管理把 Agent 工作流从临时脚本升级为可观测的生产系统。

workflowdurable-executionorchestration +2
  • · 持久工作流执行 — 工作流以事件溯源方式持久化存储,进程崩溃后可从中断点恢复执行
  • · 自动重试与超时 — 内置可配置的重试策略、超时和指数退避机制,无需手写容错代码
  • · 多语言 SDK — 提供 Go、Java、TypeScript、Python、.NET、PHP 等官方 SDK