

def produce_status_update_task_in_thread(self, input_queue):
    try:
        input_queue.put(QueueTask(STATUS_TASK_TYPE, None))
    except Exception as e:
        logger.warning('Failed to produce status updater task %r', e)
    finally:
        self.schedule_next_status_update(self)

dataset/ETHPy150Open XiaoMi/minos/owl/collector/management/commands/collect.py StatusUpdater.produce_status_update_task_in_thread/VarMisuse@54/90 `input_queue`->`self`