ecb620b20567af3a5cbc1a29f8938335e66aa669,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

        if "pending_tasks" not in wf_result or not wf_result["pending_tasks"]:
            // remove task pending status if the workflow is completed normally
            try:
                wf_status = os.path.join(os.path.expanduser("~"), ".sos", self.md5 + ".status")
                if os.path.isfile(wf_status):
                    os.remove(wf_status)
            except Exception as e:
                env.logger.warning("Failed to clear workflow status file: {}".format(e))
        if exec_error.errors:
            failed_steps, pending_steps = dag.pending()

Instances