重构工作流活动选项初始化,以实现更清晰的上下文处理

This commit is contained in:
longpeng 2025-06-20 16:28:18 +08:00
parent e9336e1af4
commit fa70f376f4

View File

@ -14,7 +14,7 @@ func TestRunWorkflow(ctx workflow.Context, input *pb.TestRunInput) (*pb.TestRunO
logger := workflow.GetLogger(ctx)
logger.Info("TestRunWorkflow started", "runID", input.RunId)
ao := workflow.ActivityOptions{
ctx = workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
StartToCloseTimeout: 10 * time.Minute, // Activity 执行超时时间
HeartbeatTimeout: 30 * time.Second, // Heartbeat 防止 Worker 假死
RetryPolicy: &temporal.RetryPolicy{ // Activity 级别的重试策略
@ -24,8 +24,7 @@ func TestRunWorkflow(ctx workflow.Context, input *pb.TestRunInput) (*pb.TestRunO
MaximumAttempts: 3,
NonRetryableErrorTypes: []string{"NonRetryableErrorType"}, // 自定义不可重试的错误
},
}
ctx = workflow.WithActivityOptions(ctx, ao)
})
var (
apiResults []*pb.ApiTestResult