else:
env.logger.trace("Start submitting {} (status: {})".format(tid, self.task_status.get(tid, "unknown")))
t = concurrent.futures.ThreadPoolExecutor(max_workers=1)
self.submitting_tasks[tid] = (t, t.submit(self.execute_task, tid))//
with threading.Lock():
for tid in to_run:
self.pending_tasks.remove(tid)
After Change
if self._status_checker is None:
self._status_checker = self._thread_workers.submit(self.query_tasks, self.running_tasks, 1)
continue
elif self._status_checker.running():
time.sleep(0.01)continueelse:
status_output = self._status_checker.result()
self._status_checker = None