diff options
| -rw-r--r-- | pym/_emerge/CompositeTask.py | 4 | ||||
| -rw-r--r-- | pym/portage/util/_async/PopenProcess.py | 4 |
2 files changed, 8 insertions, 0 deletions
diff --git a/pym/_emerge/CompositeTask.py b/pym/_emerge/CompositeTask.py index 3e434780b..40cf8596b 100644 --- a/pym/_emerge/CompositeTask.py +++ b/pym/_emerge/CompositeTask.py @@ -142,6 +142,10 @@ class CompositeTask(AsynchronousTask): a task. """ + try: + task.scheduler = self.scheduler + except AttributeError: + pass task.addExitListener(exit_handler) self._current_task = task task.start() diff --git a/pym/portage/util/_async/PopenProcess.py b/pym/portage/util/_async/PopenProcess.py index c3ae6e9db..37d32f260 100644 --- a/pym/portage/util/_async/PopenProcess.py +++ b/pym/portage/util/_async/PopenProcess.py @@ -14,6 +14,10 @@ class PopenProcess(SubProcess): def _start(self): if self.pipe_reader is not None: + try: + self.pipe_reader.scheduler = self.scheduler + except AttributeError: + pass self.pipe_reader.addExitListener(self._pipe_reader_exit) self.pipe_reader.start() |