init

temporalio · Nov 6, 2024 · da4a538 · da4a538
1 parent df12b9a
commit da4a538
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 0 deletions.
diff --git a/common/dynamicconfig/constants.go b/common/dynamicconfig/constants.go
@@ -37,6 +37,9 @@ import (
 )
 
 var (
+	// TEST ONLY DO NOT LAND
+	HistoryShouldFailReplicationTask = "history.shouldFailReplicationTask"
+
 	// keys for dynamic config itself
 	DynamicConfigSubscriptionCallback = NewGlobalTypedSetting(
 		"dynamicconfig.subscriptionCallback",

diff --git a/service/history/configs/config.go b/service/history/configs/config.go
@@ -376,6 +376,8 @@ type Config struct {
 	BreakdownMetricsByTaskQueue dynamicconfig.BoolPropertyFnWithTaskQueueFilter
 
 	LogAllReqErrors dynamicconfig.BoolPropertyFnWithNamespaceFilter
+
+	ShouldFailReplicationTask dynamicconfig.BoolPropertyFn
 }
 
 // NewConfig returns new service config with default values

diff --git a/service/history/replication/executable_history_task.go b/service/history/replication/executable_history_task.go
@@ -119,6 +119,10 @@ func (e *ExecutableHistoryTask) QueueID() interface{} {
 }
 
 func (e *ExecutableHistoryTask) Execute() error {
+	if e.Config.ShouldFailReplicationTask() {
+		return serviceerror.NewInvalidArgument("forced replication error")
+	}
+
 	if e.TerminalState() {
 		return nil
 	}