':param ds: ds to take data from
:param queue: output queue to put results in'

def __init__(self, ds, queue, reset_after_spawn=True):

    super(PrefetchProcess, self).__init__()
    self.ds = ds
    self.queue = queue
    self.reset_after_spawn = reset_after_spawn
