(slots_cache)
| 3368 | original_check_slots_coverage = nm.check_slots_coverage |
| 3369 | |
| 3370 | def check_slots_coverage(slots_cache): |
| 3371 | # Pause initialization after it has rebuilt the temporary slots |
| 3372 | # cache, so move_slot runs during a deterministic refresh window. |
| 3373 | initialize_paused.set() |
| 3374 | if not allow_initialize_to_finish.wait(timeout=5): |
| 3375 | raise TimeoutError("Timed out waiting for move_slot worker") |
| 3376 | return original_check_slots_coverage(slots_cache) |
| 3377 | |
| 3378 | def initialize_worker(): |
| 3379 | """Reinitialize the cluster""" |
nothing calls this directly
no test coverage detected