clean replication task processor after disconnect (#3882)

yux0 · web-flow · commit dbeab313e022 · 2023-02-01T16:24:10.000-08:00
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

Original file line number	Diff line number	Diff line change
`@@ -182,8 +182,8 @@ func (r *taskProcessorManagerImpl) handleClusterMetadataUpdate(`
`182`	`182`	`}`
`183`	`183`	`for _, processor := range r.taskProcessors[clusterName] {`
`184`	`184`	`processor.Stop()`
`185`		`- delete(r.taskProcessors, clusterName)`
`186`	`185`	`}`
	`186`	`+ delete(r.taskProcessors, clusterName)`
`187`	`187`	`}`
`188`	`188`
`189`	`189`	`// Case 2 and Case 3`