

def schedule_next_status_update(self, input_queue):
    wait_time = self.collector_config.period
    reactor.callFromThread(reactor.callLater, wait_time, self.produce_status_update_task, input_queue)

dataset/ETHPy150Open XiaoMi/minos/owl/collector/management/commands/collect.py StatusUpdater.schedule_next_status_update/original