diff --git a/SAS/TMSS/backend/src/tmss/tmssapp/subtasks.py b/SAS/TMSS/backend/src/tmss/tmssapp/subtasks.py index 81b87bb5146ac302353b19f9b9a818409a033fde..725c862b5f7186f37fd6d38ea7afff07361de096 100644 --- a/SAS/TMSS/backend/src/tmss/tmssapp/subtasks.py +++ b/SAS/TMSS/backend/src/tmss/tmssapp/subtasks.py @@ -6,7 +6,7 @@ from functools import cmp_to_key from collections.abc import Iterable from math import ceil from lofar.common.ring_coordinates import RingCoordinates -from os.path import split_ext +from os.path import splitext from lofar.common.datetimeutils import formatDatetime, round_to_second_precision from lofar.common import isProductionEnvironment @@ -1363,7 +1363,7 @@ def _create_pulsar_pipeline_output_dataproducts_and_transforms(pipeline_subtask: for input_dp in input_dps: is_coherent = input_dp.specifications_doc["coherent"] - output_dp = Dataproduct(filename="%s.tar" % (splitext(input_dp.filename)[0],) # .h5 -> .tar + output_dp = Dataproduct(filename="%s.tar" % (splitext(input_dp.filename)[0],), # .h5 -> .tar directory=directory+("cs/" if is_coherent else "is/"), dataformat=dataformat, datatype=datatype, @@ -1399,7 +1399,7 @@ def _create_pulsar_pipeline_output_dataproducts_and_transforms(pipeline_subtask: return dataproduct.filename.split("_")[0] # construct how input dataproducts map onto the summaries - summary_mapping = {dp: (dp_obsid(dp), dp.specifications_doc["coherent"]) for dp in input_dps)} + summary_mapping = {dp: (dp_obsid(dp), dp.specifications_doc["coherent"]) for dp in input_dps} summaries = set(summary_mapping.values()) summary_dps = {(obsid, is_coherent): Dataproduct(filename="L%s_summary%s.tar" % (obsid, "CS" if is_coherent else "IS"),