98cf326ac0db20159996a1095ff1e8dba80b0465,sos/actions.py,,sos_run,#Any#,481

Before Change

            if env.max_jobs == 1:
                return Base_Executor(wf, args=env.sos_dict["__args__"], nested=True).run()
            else:
                return MP_Executor(wf, args=env.sos_dict["__args__"], nested=True).run()
        elif env.__task_engine__ == "rq":
            return RQ_Executor(wf, args=env.sos_dict["__args__"], nested=True).run()
        elif env.__task_engine__ == "celery":
            return Celery_Executor(wf, args=env.sos_dict["__args__"], nested=True).run()

After Change

                    except Exception as e:
                        print("Failed to load queue executor {}: {}".format(entrypoint.name, e))

            if not executor_class:
                sys.exit("Could not locate specified queue executor {}".format(env.__task_engine__))
        else:
            if env.max_jobs == 1:
                executor_class = Base_Executor
            else:

Instances