clean replication task processor after disconnect (temporalio#3882)

jleach4 · Feb 2, 2023 · dbeab31 · dbeab31
1 parent cbd73e0
commit dbeab31
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/service/history/replication/task_processor_manager.go b/service/history/replication/task_processor_manager.go
@@ -182,8 +182,8 @@ func (r *taskProcessorManagerImpl) handleClusterMetadataUpdate(
 		}
 		for _, processor := range r.taskProcessors[clusterName] {
 			processor.Stop()
-			delete(r.taskProcessors, clusterName)
 		}
+		delete(r.taskProcessors, clusterName)
 	}
 
 	// Case 2 and Case 3