From c6c465ff5d682ef19ae12709e7f80c7fa3941e37 Mon Sep 17 00:00:00 2001
From: Giulio Eulisse <10544+ktf@users.noreply.github.com>
Date: Tue, 10 Nov 2020 10:01:19 +0100
Subject: [PATCH] Update DataProcessingDevice.cxx

---
 Framework/Core/src/DataProcessingDevice.cxx | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/Framework/Core/src/DataProcessingDevice.cxx b/Framework/Core/src/DataProcessingDevice.cxx
index 23479c1c539c7..734eb97bf5253 100644
--- a/Framework/Core/src/DataProcessingDevice.cxx
+++ b/Framework/Core/src/DataProcessingDevice.cxx
@@ -499,6 +499,14 @@ void DataProcessingDevice::doPrepare(DataProcessorContext& context)
     auto& channel = context.spec->inputChannels[ci];
     auto& info = context.state->inputChannelInfos[ci];
 
+    // If at least one channel is complete, we keep polling for the remaining
+    // stuff.
+    // FIXME: this is definitely not what we want, but
+    // it should get the analysis working.
+    if (info.state == InputChannelState::Completed) {
+  	  *context.wasActive = true;
+    }
+
     if (info.state != InputChannelState::Completed && info.state != InputChannelState::Pull) {
       context.allDone = false;
     }