Skip to content

Commit

Permalink
Add additional quanta information for pipetask run
Browse files Browse the repository at this point in the history
  • Loading branch information
leeskelvin committed Oct 10, 2022
1 parent dba8530 commit 7b56b1b
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion python/lsst/pipe/base/graph/graph.py
Original file line number Diff line number Diff line change
Expand Up @@ -440,7 +440,7 @@ def getQuantaForTask(self, taskDef: TaskDef) -> FrozenSet[Quantum]:
The `set` of `Quantum` that is associated with the specified
`TaskDef`.
"""
return frozenset(node.quantum for node in self._taskToQuantumNode[taskDef])
return frozenset(node.quantum for node in (self._taskToQuantumNode.get(taskDef) or tuple()))

def getNodesForTask(self, taskDef: TaskDef) -> FrozenSet[QuantumNode]:
"""Return all the `QuantumNodes` associated with a `TaskDef`.
Expand Down

0 comments on commit 7b56b1b

Please sign in to comment.