code: private void partitionFinished(PartitionReplyMsg msg) {
  
          JoblogUtil.logToJobLogAndTraceOnly(Level.FINE, "partition.ended", new Object[] {
                                                                                           msg.getPartitionPlanConfig().getPartitionNumber(),
                                                                                           msg.getBatchStatus(),
                                                                                           msg.getExitStatus(),
                                                                                           msg.getPartitionPlanConfig().getStepName(),
                                                                                           msg.getPartitionPlanConfig().getTopLevelNameInstanceExecutionInfo().getInstanceId(),
                                                                                           msg.getPartitionPlanConfig().getTopLevelNameInstanceExecutionInfo().getExecutionId() },
                                             logger);
  
          finishedWork.add(msg);
      }
docs: Issue message for partition finished and add it to the finishedWork list.