Skip to content

Commit 0273913

Browse files
committed
don't use global for scattered_p
1 parent f508727 commit 0273913

1 file changed

Lines changed: 1 addition & 10 deletions

File tree

ogcore/SS.py

Lines changed: 1 addition & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -294,7 +294,7 @@ def inner_loop(outer_loop_vars, p, client):
294294

295295
if client:
296296
# Scatter p only once and only if client not equal None
297-
# scattered_p_future = client.scatter(p, broadcast=True)
297+
scattered_p_future = client.scatter(p, broadcast=True)
298298

299299
# Launch in parallel with submit (or map)
300300
futures = []
@@ -1253,15 +1253,6 @@ def run_SS(p, client=None):
12531253
results
12541254
12551255
"""
1256-
1257-
# Definte a scattered version of the parameters, p at the module
1258-
# level so that it can be used in functions called by Dask
1259-
global scattered_p_future
1260-
if client:
1261-
scattered_p_future = client.scatter(p, broadcast=True)
1262-
else:
1263-
scattered_p_future = p
1264-
12651256
# Create list of deviation factors for initial guesses of r and TR
12661257
dev_factor_list = [
12671258
[1.00, 1.0],

0 commit comments

Comments
 (0)