We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d315268 commit 6ca39f7Copy full SHA for 6ca39f7
artiq/management/scheduler.py
@@ -98,8 +98,8 @@ def _run_periodic(self):
98
99
@asyncio.coroutine
100
def _schedule(self):
101
- next_periodic = yield from self._run_periodic()
102
while True:
+ next_periodic = yield from self._run_periodic()
103
ev_queue = asyncio.Task(self.queue_count.acquire())
104
ev_periodic = asyncio.Task(self.periodic_modified.wait())
105
done, pend = yield from asyncio.wait(
@@ -109,7 +109,7 @@ def _schedule(self):
109
for t in pend:
110
t.cancel()
111
112
+ yield from self._run_periodic()
113
if ev_queue in done:
114
rid, run_params, timeout = self.queued.pop(0)
115
result = yield from self._run(rid, run_params, timeout)
0 commit comments