From 4c72b674445ce953850fe3e8f7c83a220ddb6cec Mon Sep 17 00:00:00 2001 From: Yuanheng Zhao <54058983+yuanheng-zhao@users.noreply.github.com> Date: Thu, 8 Jan 2026 20:35:00 +0800 Subject: [PATCH] [BugFix] Explicitly release file locks during stage worker init (#703) Signed-off-by: yuanheng --- vllm_omni/entrypoints/omni_stage.py | 2 ++ 1 file changed, 2 insertions(+) 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):