From fa70f376f486c3312cfea4f27c2394a37fc5676d Mon Sep 17 00:00:00 2001
From: longpeng <longpeng@wq.io>
Date: Fri, 20 Jun 2025 16:28:18 +0800
Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E6=9E=84=E5=B7=A5=E4=BD=9C=E6=B5=81?=
 =?UTF-8?q?=E6=B4=BB=E5=8A=A8=E9=80=89=E9=A1=B9=E5=88=9D=E5=A7=8B=E5=8C=96?=
 =?UTF-8?q?=EF=BC=8C=E4=BB=A5=E5=AE=9E=E7=8E=B0=E6=9B=B4=E6=B8=85=E6=99=B0?=
 =?UTF-8?q?=E7=9A=84=E4=B8=8A=E4=B8=8B=E6=96=87=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 workflows/workflow.go | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/workflows/workflow.go b/workflows/workflow.go
index 20ddcdf..db3c7e0 100644
--- a/workflows/workflow.go
+++ b/workflows/workflow.go
@@ -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