Initialize stream workers before processing empty (End)Paths

cms-sw · Sep 21, 2022 · 291b1f4 · 291b1f4
1 parent e2a21d3
commit 291b1f4
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/FWCore/Framework/src/StreamSchedule.cc b/FWCore/Framework/src/StreamSchedule.cc
@@ -890,6 +890,12 @@ namespace edm {
       ServiceRegistry::Operate guard(serviceToken);
       Traits::preScheduleSignal(actReg_.get(), &streamContext_);
 
+      // Data dependencies need to be set up before marking empty
+      // (End)Paths complete in case something consumes the status of
+      // the empty (EndPath)
+      workerManager_.setupResolvers(ep);
+      workerManager_.setupOnDemandSystem(info);
+
       HLTPathStatus hltPathStatus(hlt::Pass, 0);
       for (int empty_trig_path : empty_trig_paths_) {
         results_->at(empty_trig_path) = hltPathStatus;
@@ -912,9 +918,6 @@ namespace edm {
         }
       }
 
-      workerManager_.setupResolvers(ep);
-      workerManager_.setupOnDemandSystem(info);
-
       ++total_events_;
 
       //use to give priorities on an error to ones from Paths