From: Zac Medico <zmedico@gentoo.org>
Date: Tue, 16 Oct 2012 19:27:46 +0000 (-0700)
Subject: CompositeTask._start_task: propagate scheduler
X-Git-Tag: v2.2.0_alpha139~7
X-Git-Url: http://git.tremily.us/?a=commitdiff_plain;h=6de6ecc0049160f049f889b81c128e682225c55b;p=portage.git

CompositeTask._start_task: propagate scheduler
---

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