diff --git a/service/history/historyEngine.go b/service/history/historyEngine.go
index 0bfd35a2a6a..f0ce9e5b479 100644
--- a/service/history/historyEngine.go
+++ b/service/history/historyEngine.go
@@ -2695,7 +2695,7 @@ func (e *historyEngineImpl) NotifyNewReplicationTasks(
 	tasks []persistence.Task,
 ) {
 
-	if len(tasks) > 0 {
+	if len(tasks) > 0 && e.replicatorProcessor != nil {
 		e.replicatorProcessor.notifyNewTask()
 	}
 }