Fix dc config

temporalio · Oct 19, 2023 · 5e9bd8d · 5e9bd8d
1 parent 068bd38
commit 5e9bd8d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/service/history/replication/fx.go b/service/history/replication/fx.go
@@ -140,9 +140,9 @@ func SequentialTaskQueueFactoryProvider(
 ) ctasks.SequentialTaskQueueFactory[TrackableExecutableTask] {
 	return func(task TrackableExecutableTask) ctasks.SequentialTaskQueue[TrackableExecutableTask] {
 		if config.EnableReplicationTaskBatching() {
-			return NewSequentialTaskQueue(task)
+			return NewSequentialBatchableTaskQueue(task, nil, logger, metricsHandler)
 		}
-		return NewSequentialBatchableTaskQueue(task, nil, logger, metricsHandler)
+		return NewSequentialTaskQueue(task)
 	}
 }