created any_inputs_done logic for done logic

1 files changed, 3 insertions, 6 deletions

diff --git a/lib/block_task.cpp b/lib/block_task.cpp
index f18b9d4..6696b62 100644
--- a/lib/block_task.cpp
+++ b/lib/block_task.cpp
@@ -248,14 +248,11 @@ void BlockActor::handle_task(void)
 
 GRAS_FORCE_INLINE void BlockActor::conclusion(void)
 {
-
+    //missing at least one upstream provider?
     //since nothing else is coming in, its safe to mark done
-    if (this->inputs_done.all()) //no upstream providers
+    if (this->any_inputs_done() or this->forecast_fail)
     {
-        if (not this->input_queues.all_ready() or this->forecast_fail)
-        {
-            this->mark_done();
-        }
+        this->mark_done();
     }
 
     //still have IO ready? kick off another task