We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ca41bb0 commit 72fb120Copy full SHA for 72fb120
service/history/queues/executor_wrapper.go
@@ -27,6 +27,7 @@ package queues
27
import (
28
"context"
29
30
+ "go.temporal.io/server/common/headers"
31
"go.temporal.io/server/common/log"
32
"go.temporal.io/server/common/log/tag"
33
"go.temporal.io/server/common/metrics"
@@ -67,7 +68,11 @@ func (e *executorWrapper) Execute(
67
68
return e.activeExecutor.Execute(ctx, executable)
69
}
70
- return e.standbyExecutor.Execute(ctx, executable)
71
+ // for standby tasks, use preemptable callerType to avoid impacting active traffic
72
+ return e.standbyExecutor.Execute(
73
+ headers.SetCallerType(ctx, headers.CallerTypePreemptable),
74
+ executable,
75
+ )
76
77
78
func (e *executorWrapper) isActiveTask(
0 commit comments