()
| 80 | |
| 81 | def _invoke(command, *args): |
| 82 | def timeout(): |
| 83 | time.sleep(WATCHDOG_TIMEOUT) |
| 84 | if timeout.occurred is None: |
| 85 | reason = _dump_worker_log(command, "timed out") |
| 86 | timeout.occurred = reason |
| 87 | |
| 88 | timeout.occurred = None |
| 89 | timeout_thread = threading.Thread(target=timeout) |
nothing calls this directly
no test coverage detected
searching dependent graphs…