diff --git a/Framework/Core/src/DataProcessingDevice.cxx b/Framework/Core/src/DataProcessingDevice.cxx
index 79d371d8ae7b8..2e3b8c23c4ced 100644
--- a/Framework/Core/src/DataProcessingDevice.cxx
+++ b/Framework/Core/src/DataProcessingDevice.cxx
@@ -540,6 +540,7 @@ void DataProcessingDevice::fillContext(DataProcessorContext& context, DeviceCont
   context.errorHandling = &mErrorHandling;
   /// We must make sure there is no optional
   /// if we want to optimize the forwarding
+  context.canForwardEarly = false;
   for (auto& input : mSpec.inputs) {
     if (strncmp(DataSpecUtils::asConcreteOrigin(input.matcher).str, "AOD", 3) == 0) {
       context.canForwardEarly = false;