From 2c8350b00a8aa89f61441f79c58bcdcc0404bd5d Mon Sep 17 00:00:00 2001 From: asistradition Date: Thu, 29 Apr 2021 14:51:23 -0400 Subject: [PATCH] Restart workers after each amusr boostrap --- inferelator/distributed/dask_functions.py | 1 + 1 file changed, 1 insertion(+) diff --git a/inferelator/distributed/dask_functions.py b/inferelator/distributed/dask_functions.py index 55e4695d..e54d2567 100644 --- 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