

def _loadFromMySQLCallback(self, data, start):
    for row in data:
        self.addToHeap(row['uuid'], row['type'])
    if (len(data) >= 10000):
        return self._loadFromMySQL(start=(start + 10000))
    self.enqueue()
    d = BaseServer.start(self)
    return d

dataset/ETHPy150Open wehriam/awspider/awspider/servers2/scheduler.py SchedulerServer._loadFromMySQLCallback/original