Update Framework/Core/src/ArrowSupport.cxx

ktf · web-flow · commit 24c736b2442d · 2024-11-19T19:41:44.000+01:00
diff --git a/Framework/Core/src/ArrowSupport.cxx b/Framework/Core/src/ArrowSupport.cxx
@@ -472,6 +472,7 @@ o2::framework::ServiceSpec ArrowSupport::arrowBackendSpec()
         }
         std::sort(ac.requestedDYNs.begin(), ac.requestedDYNs.end(), inputSpecLessThan);
         std::sort(ac.providedDYNs.begin(), ac.providedDYNs.end(), outputSpecLessThan);
+        ac.spawnerInputs.clear();
         for (auto& input : ac.requestedDYNs) {
           if (std::none_of(ac.providedDYNs.begin(), ac.providedDYNs.end(), [&input](auto const& x) { return DataSpecUtils::match(input, x); })) {
             ac.spawnerInputs.emplace_back(input);

Original file line number	Diff line number	Diff line change
`@@ -472,6 +472,7 @@ o2::framework::ServiceSpec ArrowSupport::arrowBackendSpec()`
`472`	`472`	`}`
`473`	`473`	`std::sort(ac.requestedDYNs.begin(), ac.requestedDYNs.end(), inputSpecLessThan);`
`474`	`474`	`std::sort(ac.providedDYNs.begin(), ac.providedDYNs.end(), outputSpecLessThan);`
	`475`	`+ ac.spawnerInputs.clear();`
`475`	`476`	`for (auto& input : ac.requestedDYNs) {`
`476`	`477`	`if (std::none_of(ac.providedDYNs.begin(), ac.providedDYNs.end(), [&input](auto const& x) { return DataSpecUtils::match(input, x); })) {`
`477`	`478`	`ac.spawnerInputs.emplace_back(input);`