From 699adcce7400591b71451bef742f31dc989c5a88 Mon Sep 17 00:00:00 2001 From: s-vorobe-v Date: Fri, 26 Jan 2024 19:44:37 +0100 Subject: [PATCH] Fix inflight queue not closing --- .../internal/pkg/dataplane/snapshot/storage/storage_ydb_impl.go | 1 + 1 file changed, 1 insertion(+) 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 index 35594da5b8..c36e43a9a9 100644 --- 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