TBS

lsst-dm · Nov 26, 2024 · 359373e · 359373e
1 parent 0873cd5
commit 359373e
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/python/activator/middleware_interface.py b/python/activator/middleware_interface.py
@@ -1292,11 +1292,9 @@ def _try_pipelines(self, pipelines, in_collections, data_ids, *, label):
             except Exception as e:
                 raise PipelinePreExecutionError(f"PreExecInit failed for {pipeline_file}.") from e
             _log.info(f"Running '{pipeline_file}' on {data_ids}")
-            for taskDef in qgraph.taskGraph:
-                quanta = qgraph.getNodesForTask(taskDef)
-                for quantumNode in quanta:
-                    for refs in quantumNode.quantum.inputs.values():
-                        _log.debug(f"Running with input dataset {refs[0]}")
+            for quantum_node in qgraph.inputQuanta:
+                for refs in quantum_node.quantum.inputs.values():
+                    _log.debug(f"Running with input dataset {refs[0]}")
             try:
                 with lsst.utils.timer.time_this(
                         _log, msg=f"executor.run_pipeline ({label})", level=logging.DEBUG):