[dq] fix container destroy

1 files changed, 5 insertions, 4 deletions

diff --git a/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp b/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp
index d0da7f383b..c493d2190c 100644
--- a/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp
+++ b/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp
@@ -26,6 +26,7 @@
 #include <util/stream/pipe.h>
 #include <util/generic/size_literals.h>
 #include <util/string/cast.h>
+#include <util/string/strip.h>
 
 namespace NYql::NTaskRunnerProxy {
 
@@ -350,13 +351,13 @@ private:
             // see YQL-13760
             TShellCommand cmd1(PortoCtl, {"get", ContainerName, "anon_limit"});
             cmd1.Run().Wait();
-            i64 anonLimit = FromString<i64>(cmd1.GetOutput());
+            i64 anonLimit = FromString<i64>(Strip(cmd1.GetOutput()));
             TShellCommand cmd2(PortoCtl, {"get", ContainerName, "anon_usage"});
             cmd2.Run().Wait();
-            i64 anonUsage = FromString<i64>(cmd2.GetOutput());
+            i64 anonUsage = FromString<i64>(Strip(cmd2.GetOutput()));
             if (anonUsage >= anonLimit) {
                 TShellCommand cmd3(PortoCtl, {"set", ContainerName, "anon_limit",
-                        ToString(anonUsage+(1<<20))});
+                        ToString(anonUsage + (1 << 20))});
                 cmd3.Run().Wait();
             }
         } catch (...) {
@@ -376,7 +377,7 @@ private:
         TString exeDir = ExeName.substr(0, pos);
         TString exeName = ExeName.substr(pos+1);
 
-        TString command = InternalExeDir +"/"+ exeName + " ";
+        TString command = InternalExeDir + "/" + exeName + " ";
         for (ui64 i = 1; i < Args.size(); ++i) {
             command += Args[i] + " ";
         }