570dca355344924ca6c00fa4c14aa484312ae065,sos/sos_task.py,TaskEngine,run,#TaskEngine#,419

Before Change

            status = self.query_tasks(active_tasks)

            with threading.Lock():
                self.task_status.update(status)
                self.summarize_status()
            time.sleep(self.status_check_interval)

    def submit_task(self, task_id):

After Change

                for line in status_output.split("\n"):
                    if not line.strip():
                        continue
                    try:
                        tid, tst = line.split("\t")
                        self.task_status[tid] = tst
                    except Exception as e:
                        env.logger.warning("Unrecognized response {}: {}".format(line, e))
                self.summarize_status()
            time.sleep(self.status_check_interval)

    def submit_task(self, task_id):

Instances