Fix inflight queue not closing (#266)

ydb-platform · Jan 26, 2024 · 87bd3fb · 87bd3fb
1 parent fa1a2b1
commit 87bd3fb
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/cloud/disk_manager/internal/pkg/dataplane/snapshot/storage/storage_ydb_impl.go b/cloud/disk_manager/internal/pkg/dataplane/snapshot/storage/storage_ydb_impl.go
@@ -527,6 +527,7 @@ func (s *storageYDB) shallowCopySnapshot(
 		common.ChannelWithCancellation{}, // holeValues
 		s.shallowCopyInflightLimit,
 	)
+	defer inflightQueue.Close()
 
 	waitSaver := func() error { return nil }
 	var saverError <-chan error