code: private void addFailedWorkUnits(List<WorkUnit> previousWorkUnitsForRetry,
        MultiWorkUnitWeightedQueue multiWorkUnitWeightedQueue) {
      for (WorkUnit wu : previousWorkUnitsForRetry) {
  
        try {
          multiWorkUnitWeightedQueue.addWorkUnit(wu,
              this.fs.getFileStatus(new Path(wu.getProp(ConfigurationKeys.SOURCE_FILEBASED_FILES_TO_PULL))).getLen());
        } catch (IOException e) {
          Throwables.propagate(e);
        }
  
        LOG.info(
            "Will process file from previous workunit: " + wu.getProp(ConfigurationKeys.SOURCE_FILEBASED_FILES_TO_PULL));
  
        this.fileCount++;
      }
    }
docs: Helper method to process the failed {@link WorkUnit}s from the previous run and add them to the a
  {@link MultiWorkUnitWeightedQueue}