Show More
@@ -64,7 +64,8 b' get_task_client = _client_tub.get_task_client' | |||||
64 | MultiEngineClient = get_multiengine_client |
|
64 | MultiEngineClient = get_multiengine_client | |
65 | TaskClient = get_task_client |
|
65 | TaskClient = get_task_client | |
66 |
|
66 | |||
67 | twisted_log = StringIO() |
|
67 | # This isn't great. I should probably set this up in the ReactorInThread | |
|
68 | # class below. But, it does work for now. | |||
68 | log.startLogging(sys.stdout, setStdout=0) |
|
69 | log.startLogging(sys.stdout, setStdout=0) | |
69 |
|
70 | |||
70 | # Now we start the reactor in a thread |
|
71 | # Now we start the reactor in a thread |
@@ -245,7 +245,7 b' class LocalProcessLauncher(BaseLauncher):' | |||||
245 | self.process_transport.signalProcess(sig) |
|
245 | self.process_transport.signalProcess(sig) | |
246 |
|
246 | |||
247 | @inlineCallbacks |
|
247 | @inlineCallbacks | |
248 |
def interrupt_then_kill(self, delay= |
|
248 | def interrupt_then_kill(self, delay=2.0): | |
249 | yield self.signal('INT') |
|
249 | yield self.signal('INT') | |
250 | yield sleep_deferred(delay) |
|
250 | yield sleep_deferred(delay) | |
251 | yield self.signal('KILL') |
|
251 | yield self.signal('KILL') |
General Comments 0
You need to be logged in to leave comments.
Login now