[skip ci] Add comment for removeCollectionFlowGraph (#11737)

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
2021-11-12 19:19:50 +08:00 · 2021-11-12 19:19:50 +08:00 · be20567852
parent 3f9c5baf63
commit be20567852
1 changed files with 1 additions and 0 deletions
--- a/internal/querynode/data_sync_service.go
+++ b/internal/querynode/data_sync_service.go
@ -174,6 +174,7 @@ func (dsService *dataSyncService) startCollectionDeltaFlowGraph(collectionID Uni
 	return nil
 }

+// removeCollectionFlowGraph would remove the collection flow graph by collectionID
 func (dsService *dataSyncService) removeCollectionFlowGraph(collectionID UniqueID) {
 	dsService.mu.Lock()
 	defer dsService.mu.Unlock()