docs: @Override
      public List<Integer> getStepThreadInstancePartitionNumbersOfRelatedCompletedPartitions(
                                                                                             final StepThreadInstanceKey topLevelKey) {
  
          final EntityManager em = getPsu().createEntityManager();
  
          try {
              List<Integer> exec = new TranRequest<List<Integer>>(em) {
                  @Override
                  public List<Integer> call() throws Exception {
                      TypedQuery<Integer> query = em.createNamedQuery(TopLevelStepInstanceEntity.GET_RELATED_PARTITION_LEVEL_COMPLETED_PARTITION_NUMBERS,
                                                                      Integer.class);
                      query.setParameter("instanceId", topLevelKey.getJobInstance());
                      query.setParameter("stepName", topLevelKey.getStepName());
  
                      return query.getResultList();
                  }
              }.runInNewOrExistingGlobalTran();
              return exec;
          } finally {
              em.close();
          }
  
      }