f46e650ddf8736d3c32b1817da39412a7c34bd0a,sos/__main__.py,,cmd_execute,#Any#Any#,421

Before Change

                    raise RuntimeError("{} completed, {} dead, {} failed, {} killed)".format(
                        len([x for x in res if x=="completed"]), len([x for x in res if x=="dead"]),
                        len([x for x in res if x.startswith("failed")]), len([x for x in res if x=="killed"])))
            if any(x in ("pending", "running", "completed-old") or x.startswith("failed-old") for x in res):
                continue
            elif all(x == "completed" for x in res):
                env.logger.debug("Put results for {}".format(args.tasks))

After Change

                monitor_interval=monitor_interval, resource_monitor_interval=resource_monitor_interval)
            with open(res_file, "wb") as res_file:
                pickle.dump(res, res_file)
            if res["ret_code"] != 0 and "exception" in res:
                with open(os.path.join(os.path.expanduser("~"), ".sos", "tasks", task + ".err"), "a") as err:
                    err.write("sos execute quit with code {} and exception {}: {}\n".format(
                        res["ret_code"], res["exception"].__class__.__name__, repr(res["exception"])))
            exit_code.append(res["succ"])
        sys.exit(sum(exit_code))
    elif args.queue == "":
        from .hosts import list_queues

Instances