()
| 121 | output_queue = Queue() |
| 122 | |
| 123 | def read_output(): |
| 124 | with open(pipe_path) as file: |
| 125 | data = json.loads(file.read()) |
| 126 | output_queue.put(data) |
| 127 | |
| 128 | """ |
| 129 | Spawn a thread so that we can read the output and wait for the process concurrently. |