

def produce_aggregate_task(self, input_queue):
    reactor.callInThread(self.produce_aggregate_task_in_thread, input_queue)

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