

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](queue_task, 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/VarMisuse@45/65 `output_queue`->`queue_task`