Fix loading rope from closed pipe

1 files changed, 1 insertions, 0 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 372efc48dd..749df5783f 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
@@ -67,6 +67,7 @@ void Load(IInputStream& input, void* buf, size_t size) {
     char* p = (char*)buf;
     while (size) {
         auto len = input.Read(p, size);
+        YQL_ENSURE(len != 0);
         p += len;
         size -= len;
     }