(source, destination)
| 241 | read_lock_owner = _cli._read_runtime_lock_owner |
| 242 | |
| 243 | def pause_first(source, destination): |
| 244 | replace(source, destination) |
| 245 | if Path(destination) == directory / binary_name: |
| 246 | first_holds_lock.set() |
| 247 | if not allow_first.wait(5): |
| 248 | raise RuntimeError("test did not release first publisher") |
| 249 | |
| 250 | def observe_waiter(lock_path): |
| 251 | if threading.current_thread().name == "publisher-second": |