docs: public List<StepExecution> getStepThreadExecutionsRunning(PersistenceServiceUnit psu, final long jobExecutionId) {
  
          final EntityManager em = psu.createEntityManager();
          try {
  
              List<StepExecution> exec = new TranRequest<List<StepExecution>>(em) {
                  @Override
                  public List<StepExecution> call() throws Exception {
  
                      TypedQuery<StepExecution> query = em.createNamedQuery(StepThreadExecutionEntity.GET_STEP_THREAD_EXECUTIONIDS_BY_JOB_EXEC_AND_STATUSES_QUERY,
                                                                            StepExecution.class);
                      query.setParameter("jobExecutionId", jobExecutionId);
                      query.setParameter("status", RUNNING_STATUSES);
                      List<StepExecution> result = query.getResultList();
                      if (result == null) {
                          return new ArrayList<StepExecution>();
                      }
                      return result;
                  }
              }.runInNewOrExistingGlobalTran();
              return exec;
          } finally {
              em.close();
          }
      }