def _loadFromMySQLCallback(self, data, start):
        # Add rows to heap. The second argument is interval, would be
        # based on the plugin's interval setting, random for now.
        for row in data:
            self.addToHeap(row["uuid"], row["type"])
        # Load next chunk.
        if len(data) >= 10000:
            return self._loadFromMySQL(start=start + 10000)
        # Done loading, start queuing
        self.enqueue()
        d = BaseServer.start(self)
        return d
dataset/ETHPy150Open wehriam/awspider/awspider/servers2/scheduler.py/SchedulerServer._loadFromMySQLCallback/original