Skip to content

Commit

Permalink
fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
mgovorcin committed Aug 17, 2023
1 parent 4bd35aa commit 0b9617f
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions tools/ARIAtools/tsSetup_dask.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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,
Expand Down

0 comments on commit 0b9617f

Please sign in to comment.