@@ -385,6 +385,15 @@ void WorkflowHelpers::injectServiceDevices(WorkflowSpec& workflow, ConfigContext
385385 auto outputSpecLessThan = [](OutputSpec const & lhs, OutputSpec const & rhs) { return DataSpecUtils::describe (lhs) < DataSpecUtils::describe (rhs); };
386386 std::sort (ac.requestedDYNs .begin (), ac.requestedDYNs .end (), inputSpecLessThan);
387387 std::sort (ac.providedDYNs .begin (), ac.providedDYNs .end (), outputSpecLessThan);
388+
389+ DataProcessorSpec indexBuilder{
390+ " internal-dpl-aod-index-builder" ,
391+ {},
392+ {},
393+ readers::AODReaderHelpers::indexBuilderCallback (ac.requestedIDXs ),
394+ {}};
395+ AnalysisSupportHelpers::addMissingOutputsToBuilder (ac.requestedIDXs , ac.requestedAODs , ac.requestedDYNs , indexBuilder);
396+
388397 for (auto & input : ac.requestedDYNs ) {
389398 if (std::none_of (ac.providedDYNs .begin (), ac.providedDYNs .end (), [&input](auto const & x) { return DataSpecUtils::match (input, x); })) {
390399 ac.spawnerInputs .emplace_back (input);
@@ -397,15 +406,6 @@ void WorkflowHelpers::injectServiceDevices(WorkflowSpec& workflow, ConfigContext
397406 {},
398407 readers::AODReaderHelpers::aodSpawnerCallback (ac.spawnerInputs ),
399408 {}};
400-
401- DataProcessorSpec indexBuilder{
402- " internal-dpl-aod-index-builder" ,
403- {},
404- {},
405- readers::AODReaderHelpers::indexBuilderCallback (ac.requestedIDXs ),
406- {}};
407-
408- AnalysisSupportHelpers::addMissingOutputsToBuilder (ac.requestedIDXs , ac.requestedAODs , ac.requestedDYNs , indexBuilder);
409409 AnalysisSupportHelpers::addMissingOutputsToSpawner ({}, ac.spawnerInputs , ac.requestedAODs , aodSpawner);
410410
411411 AnalysisSupportHelpers::addMissingOutputsToReader (ac.providedAODs , ac.requestedAODs , aodReader);
0 commit comments