YQL-11232: Fixes

ref:1dd32ef27f1532f2e295cd3bbac9d0b00c584746

1 files changed, 1 insertions, 5 deletions

diff --git a/ydb/library/yql/core/facade/yql_facade.cpp b/ydb/library/yql/core/facade/yql_facade.cpp
index 231b751def..59bf2c52aa 100644
--- a/ydb/library/yql/core/facade/yql_facade.cpp
+++ b/ydb/library/yql/core/facade/yql_facade.cpp
@@ -1394,12 +1394,8 @@ bool TProgram::HasActiveProcesses() {
 }
 
 bool TProgram::NeedWaitForActiveProcesses() {
-    bool flag = HasActiveProcesses();
-    if (!flag) {
-        return false;
-    }
     for (const auto& dp : DataProviders_) {
-        if (dp.WaitForActiveProcesses) {
+        if (dp.HasActiveProcesses && dp.HasActiveProcesses() && dp.WaitForActiveProcesses) {
             return true;
         }
     }