@@ -338,6 +338,21 @@ def _apply_for_date(
338338 l2_handler .version = 1 # set version to 0 for the output file naming
339339 outputManager .add_file (L2_file , l2_handler )
340340
341+ cleanup_workfolder_after_apply (
342+ app_settings ,
343+ workScienceFile ,
344+ workLayers ,
345+ workRotationFile ,
346+ L2_files ,
347+ offset_file ,
348+ )
349+
350+ logger .info (f"Apply complete for date { date } . Temporary files cleaned up." )
351+
352+
353+ def cleanup_workfolder_after_apply (
354+ app_settings , workScienceFile , workLayers , workRotationFile , L2_files , offset_file
355+ ):
341356 files_to_cleanup : list [Path ] = [
342357 offset_file ,
343358 * L2_files ,
@@ -347,10 +362,17 @@ def _apply_for_date(
347362 if workRotationFile :
348363 files_to_cleanup .append (workRotationFile )
349364
365+ # add the .csv version of all layer files to the cleanup list as well
366+ for layer_file in workLayers :
367+ if layer_file .suffix == ".json" :
368+ corresponding_csv = layer_file .with_suffix (".csv" )
369+ if corresponding_csv .exists ():
370+ files_to_cleanup .append (corresponding_csv )
371+
350372 work_folder_resolved = app_settings .work_folder .resolve ()
351373 for temp_file in files_to_cleanup :
352374 temp_file_resolved = temp_file .resolve ()
353- if (
375+ if temp_file_resolved . exists () and (
354376 temp_file_resolved == work_folder_resolved
355377 or work_folder_resolved in temp_file_resolved .parents
356378 ):
@@ -361,8 +383,6 @@ def _apply_for_date(
361383 f"Skipping deletion of file outside work folder '{ app_settings .work_folder } ': { temp_file } "
362384 )
363385
364- logger .info (f"Apply complete for date { date } . Temporary files cleaned up." )
365-
366386
367387def _setup_zero_calibration_layer (
368388 work_folder : Path , workScienceFile : Path , content_date : datetime
0 commit comments