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)