class_docstr: A callback to increase the requested epoch for the data producer.
  
  The reason why we need this is because we can only buffer a limited amount of
  data. So we keep a moving window to represent the buffer. This is to move the
  one of the window's boundaries for each epoch.
class_docstr_tok: ["A","callback","to","increase","the","requested","epoch","for","the","data","producer",".","The","reason","why","we","need","this","is","because","we","can","only","buffer","a","limited","amount","of","data",".","So","we","keep","a","moving","window","to","represent","the","buffer",".","This","is","to","move","the","one","of","the","window","'s","boundaries","for","each","epoch","."]
code: def __init__(self, producer):
      self._producer = producer
  
imports: from __future__ import absolute_import
  from __future__ import division
  from __future__ import print_function
  import json
  import yaml
  import os
  import sys
  import tensorflow
  from absl import app
  from absl import flags
  from absl import logging
  from os.path import expanduser
  from tensorflow_addons.optimizers import LazyAdam
  from utils.recommendation import constants
  from utils.recommendation import movielens
  from utils.recommendation import ncf_common
  from utils.recommendation import ncf_input_pipeline
  from utils.recommendation import neumf_model
  from utils.flags import core
  from utils.logs import logger
  from utils.logs import mlperf_helper
  from utils.misc import keras_utils
  from utils.misc import model_helpers
  from autodist import AutoDist
  from autodist.strategy.ps_strategy import PS
  from autodist.strategy.ps_lb_strategy import PSLoadBalancing
  from autodist.strategy.partitioned_ps_strategy import PartitionedPS
  from autodist.strategy.all_reduce_strategy import AllReduce
  from autodist.strategy.parallax_strategy import Parallax
label_desc: Use image node_id 1 to create a new IncrementEpochCallback object from inherited base classes: tf.keras.callbacks with example: obj = IncrementEpochCallback(producer)