SuperAPI AI 工具集

forze-temporal-workflows

办公与效率

查看项目

更新于 10-16 01:20

技能介绍

用途:在 Forze 应用中接入 Temporal 持久化工作流。核心应用依赖持久化工作流契约,forze_temporal 提供 Temporal 适配器,适用于启动、发信号、更新、查询或测试由工作流支撑的处理器。

主要能力:用 DurableWorkflowSpec 定义工作流(含 DurableWorkflowInvokeSpec 的入参与返回类型、DurableWorkflowSignalSpec 信号);spec 名称即依赖路由,需与 TemporalDepsModule.workflows 匹配。运行时通过 TemporalClient、TemporalConfig、TemporalDepsModule 与 temporal_lifecycle_step 装配依赖与生命周期;workflows 为空时只注册 TemporalClientDepKey。处理器用 ctx.deps.resolve_configurable 解析 DurableWorkflowCommandDepKey、DurableWorkflowQueryDepKey 等端口,没有 ctx.workflow_command(...) 辅助方法。支持 Temporal Schedules API 的调度(upsert 与 DurableWorkflowScheduleBootstrap 声明式引导),以及用 ExecutionContextInterceptor、TemporalContextCodec 跨客户端/worker 边界传递 InvocationMetadata、AuthnIdentity、TenantIdentity。

使用方式:定义 spec 后注册到 DepsRegistry 与 LifecyclePlan,在 OperationRegistry 上注册处理器;调度需把同一 workflow 配置映射传给 lifecycle。测试时可为命令/查询/调度依赖键注册假工厂。

限制与反模式:调度需要支持 Schedules API 的 Temporal 服务器,不适用于时间跳跃测试环境;任务队列应放在 TemporalWorkflowConfig 而非 DurableWorkflowSpec;处理器不应使用原始 Temporal SDK 类型;不要跳过 lifecycle;身份或关联重要时需在客户端与 worker 都注册拦截器。其余细节暂未提供。