From 0b9617f1dd5a591748d5f738bbb78b5cf9c000f3 Mon Sep 17 00:00:00 2001 From: mgovorcin Date: Thu, 17 Aug 2023 08:07:45 -0700 Subject: [PATCH] fix typo --- tools/ARIAtools/tsSetup_dask.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/tools/ARIAtools/tsSetup_dask.py b/tools/ARIAtools/tsSetup_dask.py index f53f4959..b29b3a5d 100644 --- a/tools/ARIAtools/tsSetup_dask.py +++ b/tools/ARIAtools/tsSetup_dask.py @@ -493,7 +493,8 @@ def main(inps=None): exportCoherenceAmplitude(product_dict, bbox_file, prods_TOTbbox, arrres, inps.workdir, - mask=inps.mask, n_threads=inps.num_threads, n_jobs=inps.n_jobs) + mask=inps.mask, n_threads=inps.num_threads, + n_jobs=inps.n_jobs) # Export Imaging Geometry # Note sure do we need lookAngle here @@ -511,11 +512,11 @@ def main(inps=None): # Hack solution to stop leaking, run dask Client in loop # restart cluster/Client after every iteration for n in range(0, max_jobs, inps.n_jobs): - if n + n_jobs > len(product_dict): + if n + inps.n_jobs > len(product_dict): print('Loop:', [n, max_jobs]) product_subset = product_dict[n:max_jobs] else: - print('Loop:', [n, n + n_jobs]) + print('Loop:', [n, n + inps.n_jobs]) product_subset = product_dict[n:n+inps.n_jobs] exportImagingGeometry(product_subset,