9e805c5f17d868a9d2a266e96600cfdbdee9dbfa,sos/sos_executor.py,Base_Executor,run,#Base_Executor#Any#Any#Any#Any#,591

Before Change

                        p, r = n._host._task_engine.get_tasks()
                        pending_tasks.extend(p)
                        running_tasks.extend(r)
                    if not pending_tasks:
                        wf_result["pending_tasks"] = running_tasks
                        env.logger.info("SoS exists with {} running tasks".format(len(running_tasks)))
                        for task in running_tasks:
                            env.logger.info(task)
                        break
                else:
                    time.sleep(0.1)
            // close all processes
        except Exception as e:

After Change

                        p, r = n._host._task_engine.get_tasks()
                        pending_tasks.extend(p)
                        running_tasks.extend(r)
                    if not pending_tasks and running_tasks:
                        raise PendingTasks(running_tasks)
                else:
                    time.sleep(0.1)
        except PendingTasks as e:
            self.record_quit_status(e.tasks)

Instances