Restart workers after each amusr boostrap

flatironinstitute · Apr 29, 2021 · 2c8350b · 2c8350b
1 parent 8efaf36
commit 2c8350b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/inferelator/distributed/dask_functions.py b/inferelator/distributed/dask_functions.py
@@ -81,6 +81,7 @@ def response_maker(y_df, i):
 
     DaskController.client.cancel(scatter_x)
     DaskController.client.cancel(scatter_priors)
+    DaskController.client.restart()
 
     return result_list