Release lock when return function

Signed-off-by: Cai Zhang <[email protected]>
milvus-io · Dec 30, 2024 · 2045c12 · 2045c12
1 parent 015e50e
commit 2045c12
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/datacoord/compaction.go b/internal/datacoord/compaction.go
@@ -214,6 +214,7 @@ func (c *compactionPlanHandler) schedule() []CompactionTask {
 
 	c.executingGuard.Lock()
 	if len(c.executingTasks) >= parallelism {
+		c.executingGuard.Unlock()
 		return selected
 	}
 	c.executingGuard.Unlock()