(self, output)
| 20 | pipe.close() |
| 21 | |
| 22 | def _create_thread(self, output): |
| 23 | # Creates a new queue and thread object to watch based on the output pipe sent |
| 24 | q = Queue() |
| 25 | t = threading.Thread(target=self._read_output, args=(output, q)) |
| 26 | t.daemon = True |
| 27 | return (q,t) |
| 28 | |
| 29 | def _stream_output(self, comm, shell = False): |
| 30 | output = error = "" |