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()