We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cfea274 commit 07cf690Copy full SHA for 07cf690
1 file changed
unilabos/app/ws_client.py
@@ -1184,6 +1184,11 @@ def _send_busy_status(self):
1184
logger.debug(f"[QueueProcessor] Sending busy status for {len(queued_jobs)} queued jobs")
1185
1186
for job_info in queued_jobs:
1187
+ # 快照可能已过期:在遍历过程中 end_job() 可能已将此 job 移至 READY,
1188
+ # 此时不应再发送 busy/need_more,否则会覆盖已发出的 free=True 通知
1189
+ if job_info.status != JobStatus.QUEUE:
1190
+ continue
1191
+
1192
message = {
1193
"action": "report_action_state",
1194
"data": {
0 commit comments