

def produce_aggregate_task_in_thread(self, input_queue):
    try:
        e.put(QueueTask(AGGREGATE_TASK_TYPE, None))
    except Exception as e:
        logger.warning('Failed to produce aggregate task %r', e)
    finally:
        self.schedule_next_aggregation(input_queue)

dataset/ETHPy150Open XiaoMi/minos/owl/collector/management/commands/collect.py RegionOperationMetricAggregator.produce_aggregate_task_in_thread/VarMisuse@16/25 `input_queue`->`e`