Hatchet项目v0.57.0版本发布：三大SDK全面升级

项目简介

Hatchet是一个现代化的分布式工作流引擎，它帮助开发者构建、运行和管理复杂的工作流系统。通过提供多语言SDK支持，Hatchet让开发者能够轻松定义任务之间的依赖关系，并可靠地执行这些任务。最新发布的v0.57.0版本带来了Python、Typescript和Go三大SDK的重大更新，显著提升了类型安全性和开发体验。

SDK全面升级概述

v0.57.0版本的核心改进集中在三大SDK上，每个SDK都进行了架构重构和功能增强。这些改进主要围绕以下几个关键目标：

1. 增强类型检查和验证能力
2. 提供更直观的API设计
3. 改善大型代码库中的开发体验
4. 提升生产环境下的可靠性

Python SDK深度解析

工作流定义新范式

新版Python SDK引入了全新的工作流定义方式。现在开发者可以使用hatchet.workflow装饰器创建Workflow对象，或者使用hatchet.task创建简单的Standalone对象。这种面向对象的API设计带来了几个显著优势：

• 工作流对象可以在代码库中轻松复用
• 内置的run和schedule方法简化了工作流执行
• 输入参数在运行时自动进行类型检查
• 消除了使用魔法字符串指定工作流名称的需求

类型安全与Pydantic集成

新版SDK深度集成了Pydantic框架，为工作流输入和任务输出提供了强大的类型验证能力：

1. 任务输入现在必须是Pydantic模型，默认使用EmptyModel作为基础类型
2. 工作流可以指定input_validator来验证输入数据
3. 任务返回值被限制为JSONSerializableMapping或Pydantic模型，确保与引擎兼容

任务依赖关系改进

任务间的依赖关系管理也进行了重大改进：

• 父任务现在通过Task对象引用，而非字符串名称
• 使用ctx.task_output(my_task)获取父任务输出时进行类型检查
• 工作流输入直接作为任务函数的第一个参数传递，取代了旧的context.workflow_input()方式

其他重要变更

1. 配置管理：ClientConfig现在使用Pydantic Settings，移除了旧的静态工厂方法
2. 异步支持：统一使用aio_前缀标识异步方法，如aio_run
3. 命名规范：所有客户端方法现在使用动词命名，如hatchet.runs.get_result
4. 时间处理：支持datetime.timedelta而不仅仅是时间字符串

Typescript SDK创新特性

工厂模式API设计

Typescript SDK转向了工厂模式，使工作流定义更加直观：

const simple = hatchet.task({
  name: "simple",
  fn: (input: SimpleInput) => {
    return {
      TransformedMessage: input.Message.toLowerCase(),
    };
  },
});

这种设计允许直接调用simple.run(input)执行任务，完全支持类型推断。

工作流DAG构建

复杂工作流的构建现在更加类型安全：

const dag = hatchet.workflow<DagInput, DagOutput>({ name: "simple" });

const toLower = dag.task({
  name: "to-lower",
  fn: (input) => ({ TransformedMessage: input.Message.toLowerCase() }),
});

dag.task({
  name: "reverse",
  parents: [toLower],
  fn: async (input, ctx) => {
    const lower = await ctx.parentOutput(toLower);
    return {
      Original: input.Message,
      Transformed: lower.TransformedMessage.split("").reverse().join(""),
    };
  },
});

增强的管理功能

新版SDK提供了更强大的运行时管理能力：

const allFailedRuns = await hatchet.runs.list({
  statuses: [WorkflowRunStatus.FAILED],
});

await hatchet.runs.replay({ 
  ids: allFailedRuns.rows?.map(r => r.metadata.id) 
});

Go SDK重要改进

工厂模式实现

Go SDK同样采用了工厂模式：

simple := factory.NewTask(
    create.StandaloneTask{ Name: "simple-task" },
    func(ctx worker.HatchetContext, input SimpleInput) (*SimpleResult, error) {
        return &SimpleResult{
            TransformedMessage: strings.ToLower(input.Message),
        }, nil
    },
    hatchet,
)

类型安全的任务依赖

任务依赖现在通过直接引用而非字符串：

step1 := simple.Task(create.WorkflowTask{ Name: "Step1" }, ...)

simple.Task(create.WorkflowTask{
    Name: "Step2",
    Parents: []create.NamedTask{ step1 },
}, ...)

运行时管理增强

runs, _ := hatchet.Runs().List(ctx, rest.V1WorkflowRunListParams{
    Statuses: &[]rest.V1TaskStatus{rest.V1TaskStatusFAILED},
})

hatchet.Runs().Replay(ctx, rest.V1ReplayTaskRequest{
    ExternalIds: &replayIds,
})

总结

Hatchet v0.57.0版本的三大SDK升级标志着该项目在开发者体验和类型安全方面迈出了重要一步。通过引入工厂模式、增强类型系统、改进API设计，以及提供更强大的运行时管理能力，Hatchet现在能够更好地服务于需要构建复杂、可靠工作流系统的开发团队。这些改进不仅提升了开发效率，也大大增强了生产环境下的系统可靠性。