Fix bug in dsproxy

2 files changed, 6 insertions, 0 deletions

diff --git a/ydb/core/blobstorage/dsproxy/dsproxy_indexrestoreget.cpp b/ydb/core/blobstorage/dsproxy/dsproxy_indexrestoreget.cpp
index c15adde217..e2a14e45e6 100644
--- a/ydb/core/blobstorage/dsproxy/dsproxy_indexrestoreget.cpp
+++ b/ydb/core/blobstorage/dsproxy/dsproxy_indexrestoreget.cpp
@@ -292,6 +292,9 @@ public:
         for (ui32 idx = 0; idx < QuerySize; ++idx) {
             BlobStatus.emplace_back(Queries[idx].Id, Info.Get());
         }
+
+        // phantom checks are for non-index queries only
+        Y_VERIFY(!ev->PhantomCheck);
     }
 
     void Bootstrap() {
diff --git a/ydb/core/blobstorage/dsproxy/dsproxy_multiget.cpp b/ydb/core/blobstorage/dsproxy/dsproxy_multiget.cpp
index eba8d52a25..50042fc438 100644
--- a/ydb/core/blobstorage/dsproxy/dsproxy_multiget.cpp
+++ b/ydb/core/blobstorage/dsproxy/dsproxy_multiget.cpp
@@ -24,6 +24,7 @@ class TBlobStorageGroupMultiGetRequest : public TBlobStorageGroupRequestActor<TB
     const TArrayHolder<TEvBlobStorage::TEvGet::TQuery> Queries;
     const TInstant Deadline;
     const bool IsInternal;
+    const bool PhantomCheck;
     TArrayHolder<TEvBlobStorage::TEvGetResult::TResponse> Responses;
 
     const TInstant StartTime;
@@ -102,6 +103,7 @@ public:
         , Queries(ev->Queries.Release())
         , Deadline(ev->Deadline)
         , IsInternal(ev->IsInternal)
+        , PhantomCheck(ev->PhantomCheck)
         , Responses(new TEvBlobStorage::TEvGetResult::TResponse[QuerySize])
         , StartTime(now)
         , MustRestoreFirst(ev->MustRestoreFirst)
@@ -121,6 +123,7 @@ public:
             MustRestoreFirst, false, ForceBlockTabletData);
         ev->IsInternal = IsInternal;
         ev->ReaderTabletData = ReaderTabletData;
+        ev->PhantomCheck = PhantomCheck;
         PendingGets.emplace_back(std::move(ev), cookie);
     }