def consume_processed_result(self):
    while True: # get all the task in output queue
      try:
        queue_task = self.output_queue.get(timeout=0.5)
        if queue_task.task_type in 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/operator `==` -> `in`