Call publishPendingTags on all blocks rather than this scheduler

Signed-off-by: Matthias Kretz <m.kretz@gsi.de>
fair-acc · Sep 30, 2024 · f08ae02 · f08ae02
1 parent 714dddb
commit f08ae02
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/include/gnuradio-4.0/Scheduler.hpp b/core/include/gnuradio-4.0/Scheduler.hpp
@@ -234,7 +234,7 @@ class SchedulerBase : public Block<Derived> {
         std::lock_guard lock(_jobListsMutex);
         _graph.forEachBlockMutable([this](auto& block) {
             this->emitErrorMessageIfAny("LifecycleState -> RUNNING", block.changeState(lifecycle::RUNNING));
-            for_each_port([](auto& port) { port.publishPendingTags(); }, outputPorts<PortType::STREAM>(this));
+            for_each_port([](auto& port) { port.publishPendingTags(); }, outputPorts<PortType::STREAM>(block));
         });
         if constexpr (executionPolicy() == ExecutionPolicy::singleThreaded || executionPolicy() == ExecutionPolicy::singleThreadedBlocking) {
             assert(_nRunningJobs.load(std::memory_order_acquire) == 0UZ);