.Compile warnings

1 files changed, 10 insertions, 5 deletions

diff --git a/ydb/core/yq/libs/actors/run_actor.cpp b/ydb/core/yq/libs/actors/run_actor.cpp
index 38cc8e9eef1..3b6b6e8929d 100644
--- a/ydb/core/yq/libs/actors/run_actor.cpp
+++ b/ydb/core/yq/libs/actors/run_actor.cpp
@@ -810,11 +810,7 @@ private:
     }
 
     void Handle(TEvents::TEvRaiseTransientIssues::TPtr& ev) {
-        Fq::Private::PingTaskRequest request;
-
-        NYql::IssuesToMessage(ev->Get()->TransientIssues, request.mutable_transient_issues());
-
-        Send(Pinger, new TEvents::TEvForwardPingRequest(request), 0, RaiseTransientIssuesCookie);
+        SendTransientIssues(ev->Get()->TransientIssues);
     }
 
     void Handle(TEvDqStats::TPtr& ev) {
@@ -825,6 +821,12 @@ private:
         }
     }
 
+    void SendTransientIssues(const NYql::TIssues& issues) {
+        Fq::Private::PingTaskRequest request;
+        NYql::IssuesToMessage(issues, request.mutable_transient_issues());
+        Send(Pinger, new TEvents::TEvForwardPingRequest(request), 0, RaiseTransientIssuesCookie);
+    }
+
     i32 UpdateResultIndices() {
         i32 count = 0;
         DqGrapResultIndices.clear();
@@ -1674,6 +1676,9 @@ private:
 
     void FinishProgram(NYql::TProgram::TStatus status, const TString& message = "", const NYql::TIssues& issues = {}) {
         if (status == TProgram::TStatus::Ok || (DqGraphParams.size() > 0 && !DqGraphParams[0].GetResultType())) {
+            if (issues) {
+                SendTransientIssues(issues);
+            }
             PrepareGraphs();
         } else {
             TString abortMessage = message;