Skip to content

Commit ac6d469

Browse files
committed
Fix logs and retries
1 parent a5ca508 commit ac6d469

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

arrakis/imager.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -306,7 +306,7 @@ def run_wsclean_singuarlity(
306306
raise e
307307

308308

309-
@task(name="Image Beam", persist_result=True)
309+
@task(name="Image Beam", persist_result=True, retries=1)
310310
def image_beam(
311311
ms: Path,
312312
field_idx: int,
@@ -775,7 +775,7 @@ def cleanup(
775775
"""
776776
logger = get_run_logger()
777777

778-
logger.warn(f"Ignoring files in {ignore_files=}. ")
778+
logger.warning(f"Ignoring files in {ignore_files=}. ")
779779

780780
if not purge:
781781
logger.info("Not purging intermediate files")
@@ -919,6 +919,9 @@ def main(
919919
logger.info(f"Using {temp_dir_wsclean} as temp directory for WSClean")
920920

921921
if temp_dir_images is None:
922+
# Don't allow purge if temp_dir_images is None
923+
logger.warning("No temp directory for images specified, disabling purge.")
924+
purge = False
922925
temp_dir_images = out_dir
923926
logger.info(f"Using {temp_dir_images} as temp directory for images")
924927

0 commit comments

Comments
 (0)