working on qa passing, temp input accumulation logic

1 files changed, 2 insertions, 1 deletions

diff --git a/lib/block_task.cpp b/lib/block_task.cpp
index c1046c3..66669d1 100644
--- a/lib/block_task.cpp
+++ b/lib/block_task.cpp
@@ -191,7 +191,8 @@ void BlockActor::handle_task(void)
             if (work_noutput_items) goto forecast_again_you_jerk;
 
             //handle the case of forecast failing
-            this->mark_done();
+            //TODO accumulate input here, only done if inputs done and already accumulated
+            if (this->inputs_done[i]) this->mark_done();
             return;
         }
     }