

def schedule_next_aggregation(self, input_queue):
    wait_time = self.collector_config.period
    reactor.callFromThread(reactor.callLater, wait_time, self.produce_aggregate_task, input_queue)

dataset/ETHPy150Open XiaoMi/minos/owl/collector/management/commands/collect.py RegionOperationMetricAggregator.schedule_next_aggregation/original