code: private void cleanupWorkingDirectory() throws IOException {
      LOGGER.info("Deleting persisted work units for job " + this.jobContext.getJobId());
      stateStores.getWuStateStore().delete(this.jobContext.getJobId());
  
      // delete the directory that stores the task state files
      stateStores.getTaskStateStore().delete(outputTaskStateDir.getName());
  
      LOGGER.info("Deleting job state file for job " + this.jobContext.getJobId());
  
      if (this.stateStores.haveJobStateStore()) {
        this.stateStores.getJobStateStore().delete(this.jobContext.getJobId());
      } else {
        Path jobStateFilePath = GobblinClusterUtils.getJobStateFilePath(false, this.appWorkDir, this.jobContext.getJobId());
        this.fs.delete(jobStateFilePath, false);
      }
    }
docs: Delete persisted {@link WorkUnit}s and {@link JobState} upon job completion.