docs: @Override
      protected void threadEnd() {
          super.threadEnd();
          boolean finalStatusSent = ((RuntimePartitionExecution) getRuntimeWorkUnitExecution()).isFinalStatusSent();
  
          if (!finalStatusSent) {
              try {
                  // We only need to send Failed FINAL_STATUS message here if there was an exception and the message was not sent previously
                  partitionReplyQueue.add(new PartitionReplyMsg(PartitionReplyMsgType.PARTITION_FINAL_STATUS).setBatchStatus(BatchStatus.FAILED).setExitStatus(BatchStatus.FAILED.toString()).setPartitionPlanConfig(partitionPlanConfig));
  
              } catch (Exception e) {
                  //Just ffdc it.
              } finally {
                  partitionReplyQueue.close();
              }
          }
      }