open_pub/Uni-Lab-OS
1
0
Fork 0
mirror of https://github.com/deepmodeling/Uni-Lab-OS synced 2026-04-04 17:23:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

fit cocurrent gap

Browse Source
This commit is contained in:
Xuwznln
2026-04-02 16:01:23 +08:00
parent 25c94af755
commit 49b3c850f9
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
unilabos/app/ws_client.py
View File

@@ -1113,7 +1113,7 @@ class MessageProcessor:
"task_id": task_id, "task_id": task_id,
"job_id": job_id, "job_id": job_id,
"free": free, "free": free,
"need_more": need_more, "need_more": need_more + 1,
}, },
} }
@@ -1253,7 +1253,7 @@ class QueueProcessor:
"task_id": job_info.task_id, "task_id": job_info.task_id,
"job_id": job_info.job_id, "job_id": job_info.job_id,
"free": False, "free": False,
"need_more": 10, "need_more": 10 + 1,
}, },
} }
self.message_processor.send_message(message) self.message_processor.send_message(message)
@@ -1286,7 +1286,7 @@ class QueueProcessor:
"task_id": job_info.task_id, "task_id": job_info.task_id,
"job_id": job_info.job_id, "job_id": job_info.job_id,
"free": False, "free": False,
"need_more": 10, "need_more": 10 + 1,
}, },
} }
success = self.message_processor.send_message(message) success = self.message_processor.send_message(message)