Skip to content

Commit 0a7a9ab

Browse files
committed
fix: Clear stale dedicated merged jobs on startup
1 parent 8abe1bf commit 0a7a9ab

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

src/art/megatron/service.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -618,6 +618,7 @@ async def start_openai_server(
618618
port = (config or {}).get("server_args", {}).get("port", 8000)
619619
location = await self._start_vllm_subprocess(lora_path, port, config)
620620
if self.rollout_weights_mode == "merged":
621+
self._clear_pending_jobs()
621622
await self._sync_dedicated_merged_weights(
622623
lora_path=lora_path,
623624
step=self._latest_step,

0 commit comments

Comments
 (0)