(marker_dir: str)
| 31 | |
| 32 | @flow(log_prints=True, persist_result=True) |
| 33 | def externally_suspended_flow(marker_dir: str) -> None: |
| 34 | Path(marker_dir, STARTED_MARKER).write_text("started") |
| 35 | for index in range(TASK_COUNT): |
| 36 | write_task_marker(marker_dir, index) |
| 37 | Path(marker_dir, COMPLETED_MARKER).write_text("completed") |
| 38 | |
| 39 | |
| 40 | def _worker_output(log_path: Path) -> str: |
nothing calls this directly
no test coverage detected
searching dependent graphs…