code: @Override
      public void deleteStepThreadInstanceOfRelatedPartitions(TopLevelStepInstanceKey stepInstanceKey) {
  
          long compareInstanceId = stepInstanceKey.getJobInstance();
  
          for (StepThreadInstanceEntity stepThreadInstance : data.stepThreadInstanceData.values()) {
              if ((stepThreadInstance.getJobInstance().getInstanceId() == compareInstanceId) &&
                  (stepThreadInstance.getStepName().equals(stepInstanceKey.getStepName())) &&
                  (!(stepThreadInstance instanceof TopLevelStepInstanceEntity))) {
  
                  StepThreadInstanceKey removalKey = new StepThreadInstanceKey(stepThreadInstance);
                  data.stepThreadInstanceData.remove(removalKey);
              }
          }
      }
docs: It might seems like this should delete related partition-level step executions as well.
  
  However these are owned by the job execution, not the step thread instance.
  
  @param stepThreadInstanceKey