(self, curr_step)
Override if worker has state to store/load for checkpoints
Override if worker has state to store/load for checkpoints
Override if worker has state to store / load for checkpoints
def checkpoint(self, curr_step):
        """
        Override if worker has state to store/load for checkpoints
        """
        pass
def checkpoint ( self , curr_step ) : pass