'Reset state of the dataflow. It has to be called before producing datapoints.
For example, RNG **has to** be reset if used in the DataFlow,
otherwise it won\'t work well with prefetching, because different
processes will have the same RNG state.'

def reset_state(self):

    pass
