92d26a01d73f0bc00405f51324756ae16b9f7d4a,sos/sos_task.py,TaskEngine,run,#TaskEngine#,550

Before Change

                    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)
                    continue
                else:
                    status_output = self._status_checker.result()
                    self._status_checker = None

Instances