def runOnce(self):
        try:
            t, v = self._queue.popleft()
        except __HOLE__:
            time.sleep(0.1)
            return False

        if t == _STOP:
            return True

        self.generateRDDs(v)
        return False
dataset/ETHPy150Open douban/dpark/dpark/dstream.py/Scheduler.runOnce