

def _addToQueueComplete(self, data):
    LOGGER.info('Completed adding items into the queue...')
    self.enqueueCallLater = reactor.callLater(2, self.enqueue)

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