From c93d0301099792a4bf7b6ab84a3693adff13a160 Mon Sep 17 00:00:00 2001 From: allegroai <> Date: Sat, 20 Jul 2019 23:55:14 +0300 Subject: [PATCH] Fix support for sub-process (process pool) --- trains/utilities/async_manager.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/trains/utilities/async_manager.py b/trains/utilities/async_manager.py index 3c19441a..fd57e11d 100644 --- a/trains/utilities/async_manager.py +++ b/trains/utilities/async_manager.py @@ -28,7 +28,9 @@ class AsyncManagerMixin(object): continue # add result if result and not result.ready(): - cls._async_results[pid] = cls._async_results.get(pid, []).append(result) + if not cls._async_results.get(pid): + cls._async_results[pid] = [] + cls._async_results[pid].append(result) break finally: cls._async_results_lock.release()