

def error_callback(self, error, input_queue):
    logger.warning('%r failed to fetch: %r', self.task, error)
    try:
        self.task.last_metrics_raw = None
        self.task.last_status = Status.ERROR
        self.task.last_message = ('Error: %r' % error)
        input_queue.put(QueueTask(METRIC_TASK_TYPE, self.task))
    except Exception as e:
        logger.warning('%r failed to process error: %r', self.task, e)
        self.schedule_next_fetch(input_queue)

dataset/ETHPy150Open XiaoMi/minos/owl/collector/management/commands/collect.py MetricSource.error_callback/original