diff --git a/python/lsst/ts/externalscripts/base_make_calibrations.py b/python/lsst/ts/externalscripts/base_make_calibrations.py index bea29f37..eb03a79b 100644 --- a/python/lsst/ts/externalscripts/base_make_calibrations.py +++ b/python/lsst/ts/externalscripts/base_make_calibrations.py @@ -776,13 +776,14 @@ async def call_pipetask(self, image_type): pipeline_yaml_file = f"${{CP_PIPE_DIR}}/pipelines/_ingredients/{pipe_yaml}" # This returns the in-progress acknowledgement with the job identifier + exposure_id_string = str(exposure_ids) if len(exposure_ids) > 1 else f"({exposure_ids[0]})" ack = await self.ocps.cmd_execute.set_start( wait_done=False, pipeline=f"{pipeline_yaml_file}", version="", config=f"{config_string}", data_query=f"instrument='{self.instrument_name}' AND" - f" detector IN {self.detectors_string} AND exposure IN {exposure_ids}", + f" detector IN {self.detectors_string} AND exposure IN {exposure_id_string}", ) self.log.debug( f"Received acknowledgement of ocps command for {image_type} pipetask." @@ -997,13 +998,14 @@ async def verify_calib(self, image_type, job_id_calib): pipeline_yaml_file = f"${{CP_VERIFY_DIR}}/pipelines/{pipe_yaml}" # Verify the combined calibration + exposure_id_string = str(exposure_ids) if len(exposure_ids) > 1 else f"({exposure_ids[0]})" ack = await self.ocps.cmd_execute.set_start( wait_done=False, pipeline=f"{pipeline_yaml_file}", version="", config=f"{config_string}", data_query=f"instrument='{self.instrument_name}' AND" - f" detector IN {self.detectors_string} AND exposure IN {exposure_ids}", + f" detector IN {self.detectors_string} AND exposure IN {exposure_id_string}", ) self.log.debug( f"Received acknowledgement of ocps command for {image_type} verification."