

def schedule_next_fetch(self, input_queue):
    next_time = (self.start_time + self.collector_config.period)
    end_time = time.time()
    if (end_time < next_time):
        wait_time = (next_time - end_time)
        logger.info('%r waiting %f seconds for %s...', self.task, input_queue, self.url)
        reactor.callFromThread(reactor.callLater, wait_time, self.fetch_metrics, input_queue)
    else:
        reactor.callFromThread(self.fetch_metrics, input_queue)

dataset/ETHPy150Open XiaoMi/minos/owl/collector/management/commands/collect.py MetricSource.schedule_next_fetch/VarMisuse@61/98 `wait_time`->`input_queue`