diff --git a/src/coffea/jetmet_tools/CorrectedJetsFactory.py b/src/coffea/jetmet_tools/CorrectedJetsFactory.py index 86607fef4..616bf1af0 100644 --- a/src/coffea/jetmet_tools/CorrectedJetsFactory.py +++ b/src/coffea/jetmet_tools/CorrectedJetsFactory.py @@ -434,6 +434,6 @@ def build_variant(unc, template, jetpt, jetpt_orig, jetmass, jetmass_orig): _AwkwardRewrapFn(gfunc=rewrap_recordarray), out, jets, - label="corrected-jets", + label="corrected_jets", meta=out_meta, ) diff --git a/src/coffea/jetmet_tools/FactorizedJetCorrector.py b/src/coffea/jetmet_tools/FactorizedJetCorrector.py index e85b06a8f..0f752e49e 100644 --- a/src/coffea/jetmet_tools/FactorizedJetCorrector.py +++ b/src/coffea/jetmet_tools/FactorizedJetCorrector.py @@ -224,7 +224,7 @@ def getSubCorrections(self, **kwargs): corrections.append( func( *fargs, - dask_label=f"{self._campaign}-{self._dataera}-{self._datatype}-{self._levels[i]}-{self._jettype}", + dask_label=f"{self._campaign}_{self._dataera}_{self._datatype}_{self._levels[i]}_{self._jettype}", ) ) else: diff --git a/src/coffea/jetmet_tools/JetCorrectionUncertainty.py b/src/coffea/jetmet_tools/JetCorrectionUncertainty.py index b4583bd9c..26f43f873 100644 --- a/src/coffea/jetmet_tools/JetCorrectionUncertainty.py +++ b/src/coffea/jetmet_tools/JetCorrectionUncertainty.py @@ -168,7 +168,7 @@ def getUncertainty(self, **kwargs): uncs.append( func( *args, - dask_label=f"{self._campaign}-{self._dataera}-{self._datatype}-{self._levels[i]}-{self._jettype}", + dask_label=f"{self._campaign}_{self._dataera}_{self._datatype}_{self._levels[i]}_{self._jettype}", ) ) else: diff --git a/src/coffea/jetmet_tools/JetResolution.py b/src/coffea/jetmet_tools/JetResolution.py index bb1f5a1f3..18cb0ca02 100644 --- a/src/coffea/jetmet_tools/JetResolution.py +++ b/src/coffea/jetmet_tools/JetResolution.py @@ -159,7 +159,7 @@ def getResolution(self, **kwargs): resos.append( func( *args, - dask_label=f"{self._campaign}-{self._dataera}-{self._datatype}-{self._levels[i]}-{self._jettype}", + dask_label=f"{self._campaign}_{self._dataera}_{self._datatype}_{self._levels[i]}_{self._jettype}", ) ) else: diff --git a/src/coffea/jetmet_tools/JetResolutionScaleFactor.py b/src/coffea/jetmet_tools/JetResolutionScaleFactor.py index 58ed4a380..40f7c3b5d 100644 --- a/src/coffea/jetmet_tools/JetResolutionScaleFactor.py +++ b/src/coffea/jetmet_tools/JetResolutionScaleFactor.py @@ -155,7 +155,7 @@ def getScaleFactor(self, **kwargs): sfs.append( func( *args, - dask_label=f"{self._campaign}-{self._dataera}-{self._datatype}-{self._levels[i]}-{self._jettype}", + dask_label=f"{self._campaign}_{self._dataera}_{self._datatype}_{self._levels[i]}_{self._jettype}", ) ) else: diff --git a/src/coffea/ml_tools/helper.py b/src/coffea/ml_tools/helper.py index 2ecedbe6e..15d282879 100644 --- a/src/coffea/ml_tools/helper.py +++ b/src/coffea/ml_tools/helper.py @@ -358,7 +358,7 @@ def __call__(self, wrapper, *args): wrap, self._delayed_wrapper, *packed_args, - label=f"numpy_call_{self.__class__.__name__}_", + label=f"numpy_call_{self.__class__.__name__}", meta=wrap_meta, ) arr = unpack_ret_array(arr) diff --git a/src/coffea/nanoevents/methods/base.py b/src/coffea/nanoevents/methods/base.py index 7779340e0..a57d23c01 100644 --- a/src/coffea/nanoevents/methods/base.py +++ b/src/coffea/nanoevents/methods/base.py @@ -236,7 +236,7 @@ def _apply_global_index(self, dask_array, index): return dask_array.map_partitions( _ClassMethodFn("_apply_global_index"), index, - label="_apply_global_index", + label="apply_global_index", ) @dask_method(no_dispatch=True) diff --git a/src/coffea/nanoevents/methods/physlite.py b/src/coffea/nanoevents/methods/physlite.py index d905607fb..fc901ff67 100644 --- a/src/coffea/nanoevents/methods/physlite.py +++ b/src/coffea/nanoevents/methods/physlite.py @@ -95,7 +95,7 @@ def _get_target_offsets(load_column, event_index): ): # wrap in map_partitions if dask arrays return dask_awkward.map_partitions( - _get_target_offsets, load_column, event_index + _get_target_offsets, load_column, event_index, label="get_target_offsets" ) offsets = load_column.layout.offsets.data