Skip to content

Commit 42a6068

Browse files
committed
DPL: fix adjustment of spawnerInputs
1 parent a4f9b96 commit 42a6068

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

Framework/Core/src/ArrowSupport.cxx

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -472,19 +472,18 @@ o2::framework::ServiceSpec ArrowSupport::arrowBackendSpec()
472472
}
473473
std::sort(ac.requestedDYNs.begin(), ac.requestedDYNs.end(), inputSpecLessThan);
474474
std::sort(ac.providedDYNs.begin(), ac.providedDYNs.end(), outputSpecLessThan);
475-
std::vector<InputSpec> spawnerInputs;
476475
for (auto& input : ac.requestedDYNs) {
477476
if (std::none_of(ac.providedDYNs.begin(), ac.providedDYNs.end(), [&input](auto const& x) { return DataSpecUtils::match(input, x); })) {
478-
spawnerInputs.emplace_back(input);
477+
ac.spawnerInputs.emplace_back(input);
479478
}
480479
}
481480
// recreate inputs and outputs
482481
spawner->outputs.clear();
483482
spawner->inputs.clear();
484483
// replace AlgorithmSpec
485484
// FIXME: it should be made more generic, so it does not need replacement...
486-
spawner->algorithm = readers::AODReaderHelpers::aodSpawnerCallback(spawnerInputs);
487-
AnalysisSupportHelpers::addMissingOutputsToSpawner({}, spawnerInputs, ac.requestedAODs, *spawner);
485+
spawner->algorithm = readers::AODReaderHelpers::aodSpawnerCallback(ac.spawnerInputs);
486+
AnalysisSupportHelpers::addMissingOutputsToSpawner({}, ac.spawnerInputs, ac.requestedAODs, *spawner);
488487
}
489488

490489
if (writer != workflow.end()) {

0 commit comments

Comments
 (0)