From c1cc80ba1b8fada0a835adcdcff9e80856370d3f Mon Sep 17 00:00:00 2001 From: allegroai <> Date: Sun, 15 Dec 2019 00:10:34 +0200 Subject: [PATCH] Optimize artifacts threading --- trains/binding/artifacts.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/trains/binding/artifacts.py b/trains/binding/artifacts.py index 9e380a60..df0ae615 100644 --- a/trains/binding/artifacts.py +++ b/trains/binding/artifacts.py @@ -243,7 +243,6 @@ class Artifacts(object): self._thread = None self._flush_event = Event() self._exit_flag = False - self._thread_pool = ThreadPool() self._summary = '' self._temp_folder = [] self._task_artifact_list = [] @@ -442,7 +441,8 @@ class Artifacts(object): pass def _start(self): - if not self._thread: + """ Start daemon thread if any artifacts are registered and thread is not up yet """ + if not self._thread and self._artifacts_dict: # start the daemon thread self._flush_event.clear() self._thread = Thread(target=self._daemon)