Skip to content

Commit

Permalink
Fixed metadata task misnaming
Browse files Browse the repository at this point in the history
  • Loading branch information
BrunoSanchez committed Mar 24, 2024
1 parent 4e546be commit 43aa59d
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -59,13 +59,13 @@ class DiffimDetectorVisitAnalysisTask(AnalysisPipelineTask):
def runQuantum(self, butlerQC, inputRefs, outputRefs):
inputs = butlerQC.get(inputRefs)
detectTaskName = inputRefs.metadataDetect.datasetType.name
detectTaskName[:detectTaskName.find("_")]
detectTaskName = detectTaskName[:detectTaskName.find("_")]
metadata = inputs["metadataDetect"].metadata[detectTaskName].to_dict()
if not metadata[detectTaskName]:
if not metadata:
raise NoWorkFound("No metadata entries for detectAndMeasure.")
inputs.pop("metadataDetect")
subtractTaskName = inputRefs.metadataSubtract.datasetType.name
subtractTaskName[:subtractTaskName.find("_")]
subtractTaskName = subtractTaskName[:subtractTaskName.find("_")]
metadata |= inputs["metadataSubtract"].metadata[subtractTaskName].to_dict()
inputs.pop("metadataSubtract")
df = pd.DataFrame(metadata)
Expand Down

0 comments on commit 43aa59d

Please sign in to comment.