def process_queue_task(input_queue, output_queue):
  connection.close()
  while True:
    try:
      queue_task = input_queue.get(timeout=0.5)
      QUEUE_TASK_CALLBACK[queue_task.task_type](output_queue,
        queue_task.task_data)
    except Queue.Empty:
      logger.warning("Input Queue is empty in process %d." % os.getpid())
      continue
dataset/ETHPy150Open XiaoMi/minos/owl/collector/management/commands/collect.py/process_queue_task/original