From 0c93b89e8736a53725b9dcedaa7203be5affcdf4 Mon Sep 17 00:00:00 2001 From: Colombo Date: Wed, 22 Jan 2020 10:46:35 +0400 Subject: [PATCH] 1 --- core/joblib/SubprocessorBase.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/core/joblib/SubprocessorBase.py b/core/joblib/SubprocessorBase.py index e37e5a6..17c4d5d 100644 --- a/core/joblib/SubprocessorBase.py +++ b/core/joblib/SubprocessorBase.py @@ -55,6 +55,8 @@ class Subprocessor(object): def progress_bar_inc(self, c): self.c2s.put ( {'op': 'progress_bar_inc' , 'c':c } ) def _subprocess_run(self, client_dict, s2c, c2s): + self.s2c = s2c + self.c2s = c2s data = None try: self.on_initialize(client_dict)