d85c87182a4eb2434bf3bd4d540217ce68125949,sos/sos_task.py,TaskEngine,run,#TaskEngine#,472

Before Change

                    if self.task_status[tid] == "running":
                        env.logger.info("{} ``runnng``".format(tid))
                    elif self.task_status[tid] == "completed":
                        env.logger.info("{} ``already completed``".format(tid))
                    else:
                        self.execute_task(tid)
                //
                with threading.Lock():

After Change

                            if self.submitting_tasks[k].result():
                                self.tasks.append(k)
                            else:
                                if hasattr(env, "__task_notifier__"):
                                    env.__task_notifier__(["change-status", k, "failed"])
                                self.task_status[k] = "failed"
                    for k in submitted:
                        self.submitting_tasks.pop(k)

Instances