Fix npe for dlq retry policy (#2923)

temporalio · May 31, 2022 · 0f34935 · 0f34935
1 parent 7af6cda
commit 0f34935
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/service/history/replication/task_processor.go b/service/history/replication/task_processor.go
@@ -149,6 +149,7 @@ func NewTaskProcessor(
 			replicationTaskFetcher.getRateLimiter(),
 		}),
 		taskRetryPolicy:      taskRetryPolicy,
+		dlqRetryPolicy:       dlqRetryPolicy,
 		requestChan:          replicationTaskFetcher.getRequestChan(),
 		syncShardChan:        make(chan *replicationspb.SyncShardStatus, 1),
 		shutdownChan:         make(chan struct{}),