From 969c0d9fc1224b46ae08bf75d8ed8f214e74d3e8 Mon Sep 17 00:00:00 2001
From: Alexey Milovidov <milovidov@yandex-team.ru>
Date: Sun, 20 May 2018 08:30:47 +0300
Subject: [PATCH] Processors: experimental [#CLICKHOUSE-2948]

---
 dbms/src/Processors/Processor.h               | 2 +-
 dbms/src/Processors/tests/processors_test.cpp | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/dbms/src/Processors/Processor.h b/dbms/src/Processors/Processor.h
index 921b2686741..c154ed3835e 100644
--- a/dbms/src/Processors/Processor.h
+++ b/dbms/src/Processors/Processor.h
@@ -280,7 +280,7 @@ public:
     enum class Status
     {
         /// Processor needs some data at its inputs to proceed.
-        /// You need to run another processor to generate required input and proceed.
+        /// You need to run another processor to generate required input before proceed.
         NeedData,
 
         /// Processor cannot proceed because output port is full.
diff --git a/dbms/src/Processors/tests/processors_test.cpp b/dbms/src/Processors/tests/processors_test.cpp
index 946d237789e..b9941ab1d63 100644
--- a/dbms/src/Processors/tests/processors_test.cpp
+++ b/dbms/src/Processors/tests/processors_test.cpp
@@ -50,9 +50,6 @@ public:
 
     Status prepare() override
     {
-        if (output.hasData())
-            return Status::PortFull;
-
         if (!output.isNeeded())
             return Status::Unneeded;
 
@@ -62,6 +59,9 @@ public:
         if (!current_block)
             return Status::Async;
 
+        if (output.hasData())
+            return Status::PortFull;
+
         return Status::Ready;
     }