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)

# Region operation include : get, multiput, multidelete, checkAndPut, BulkDelete etc.
# one region operation include operation_NumOps, operation_AvgTime, operation_MaxTime and
# operation.MinTime. We aggregate operation metrics of regions to compute operation metrics
# for table and cluster
dataset/ETHPy150Open XiaoMi/minos/owl/collector/management/commands/collect.py/MetricSource.error_callback/original