diff --git a/vllm_omni/entrypoints/omni_stage.py b/vllm_omni/entrypoints/omni_stage.py index fa70e1bc2..01c6ef7dd 100644 --- a/vllm_omni/entrypoints/omni_stage.py +++ b/vllm_omni/entrypoints/omni_stage.py @@ -601,6 +601,7 @@ def _stage_worker( # or when process dies for lock_fd in lock_files: try: + fcntl.flock(lock_fd, fcntl.LOCK_UN) _os.close(lock_fd) logger.debug("Released initialization lock (fd=%s)", lock_fd) except (OSError, ValueError): @@ -1104,6 +1105,7 @@ async def _stage_worker_async( # or when process dies for lock_fd in lock_files: try: + fcntl.flock(lock_fd, fcntl.LOCK_UN) _os.close(lock_fd) logger.debug("Released initialization lock (fd=%s)", lock_fd) except (OSError, ValueError):