

def consume_processed_result(self):
    while True:
        try:
            queue_task = self.output_queue.get(timeout=0.5)
            if (metric_source_id.task_type == METRIC_TASK_TYPE):
                metric_source_id = queue_task.task_data
                self.metric_sources[metric_source_id].schedule_next_fetch(self.input_queue)
        except Queue.Empty:
            logger.warning('Output Queue is empty.')
            continue

dataset/ETHPy150Open XiaoMi/minos/owl/collector/management/commands/collect.py Command.consume_processed_result/VarMisuse@34/43 `queue_task`->`metric_source_id`