Commit 4bce8dab authored by zhuwenwen's avatar zhuwenwen
Browse files

Merge remote-tracking branch 'origin/092-scheduler_service' into v0.9.2-dev

parents 5a120438 1ff05ff4
......@@ -343,7 +343,9 @@ class Scheduler(SchedulerInterface):
break
request = self.waiting.peek_request()
if request.is_finished():
self.waiting.pop_request()
continue
# KVTransfer: skip request if still waiting for remote kvs.
if request.status == RequestStatus.WAITING_FOR_REMOTE_KVS:
is_ready = self._update_waiting_for_remote_kv(request)
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment