DRMAAExecutor.java 文件源码

@Override
public void execute(ServletContext servletContext, PlanBuilder planBuilder, Run run, boolean async) {
    SessionFactory sessionFactory = SessionFactory.getFactory();
    Session session = sessionFactory.getSession();
    try {
        session.init("");
        JobTemplate jobTemplate = createJobTemplate(servletContext, session, run);
        String jobId = enqueue(session, run, jobTemplate);
        if (async) {
            String status = waitForStatus(session, jobId);
            if (status != null) {
                run.addStatus(status, "", true);
            }
        }
        session.deleteJobTemplate(jobTemplate);
        session.exit();
    }
    catch (DrmaaException e) {
        throw new RuntimeException(e);
    }
}