YQL query dumper - fail dump if DQ uses files (#27628)

Author: loochek

ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp

@@ -768,6 +768,12 @@ class TDqExecTransformer: public TExecTransformerBase, TCounters
             return filesRes;
         }
         FlushCounter("FreezeUsedFiles");
+
+        auto& qContext = State->TypeCtx->QContext;
+        if (qContext.CanWrite() && qContext.CaptureMode() == EQPlayerCaptureMode::Full && !files.empty()) {
+            YQL_CLOG(DEBUG, ProviderDq) << "DQ full capture has not been taken: file dump is unsupported";
+            State->IsFullCaptureReady = false;
+        }
         // copy-paste }
 
         TScopedAlloc alloc(__LOCATION__, NKikimr::TAlignedPagePoolCounters(), State->FunctionRegistry->SupportsSizedAllocators());
@@ -1347,6 +1353,12 @@ class TDqExecTransformer: public TExecTransformerBase, TCounters
             return filesRes;
         }
         FlushCounter("FreezeUsedFiles");
+
+        auto& qContext = State->TypeCtx->QContext;
+        if (qContext.CanWrite() && qContext.CaptureMode() == EQPlayerCaptureMode::Full && !files.empty()) {
+            YQL_CLOG(DEBUG, ProviderDq) << "DQ full capture has not been taken: file dump is unsupported";
+            State->IsFullCaptureReady = false;
+        }
         // copy-paste }
 
         THashMap<TString, TString> secureParams;
@@ -1900,6 +1912,12 @@ class TDqExecTransformer: public TExecTransformerBase, TCounters
                 continue;
             }
             FlushCounter("FreezeUsedFiles");
+
+            auto& qContext = State->TypeCtx->QContext;
+            if (qContext.CanWrite() && qContext.CaptureMode() == EQPlayerCaptureMode::Full && !files.empty()) {
+                YQL_CLOG(DEBUG, ProviderDq) << "DQ full capture has not been taken: file dump is unsupported";
+                State->IsFullCaptureReady = false;
+            }
             // copy-paste }
 
             auto settings = std::make_shared<TDqSettings>(*commonSettings);

ydb/library/yql/providers/dq/provider/yql_dq_datasink.cpp

@@ -223,6 +223,10 @@ class TDqDataProviderSink: public TDataProviderBase {
         }
     }
 
+    bool IsFullCaptureReady() override {
+        return State->IsFullCaptureReady;
+    }
+
     const TDqState::TPtr State;
 
     TLazyInitHolder<IGraphTransformer> LogOptTransformer;

ydb/library/yql/providers/dq/provider/yql_dq_state.h

@@ -33,6 +33,7 @@ struct TDqState: public TThrRefBase {
     const TString VanillaJobMd5;
     TDqConfiguration::TPtr Settings = MakeIntrusive<TDqConfiguration>();
     bool ExternalUser;
+    bool IsFullCaptureReady = true;
 
     TMutex Mutex;
     THashMap<ui32, TOperationStatistics> Statistics;