(job: Job, pipe, stream_name: str)
| 352 | |
| 353 | |
| 354 | def _pipe_output(job: Job, pipe, stream_name: str) -> None: |
| 355 | if pipe is None: |
| 356 | return |
| 357 | for line in iter(pipe.readline, ""): |
| 358 | text = line.rstrip() |
| 359 | if text: |
| 360 | job.write_log(stream_name, text) |
| 361 | job.push("log", {"stream": stream_name, "line": text}) |
| 362 | pipe.close() |
| 363 | |
| 364 | |
| 365 | def _scan_artifacts(job: Job) -> None: |