

def fetch_metrics(self, input_queue):
    logger.info('%r fetching %s...', self.task, self.url)
    self.start_time = time.time()
    self.task.last_attempt_time = datetime.datetime.utcfromtimestamp(self.start_time).replace(tzinfo=timezone.utc)
    client.getPage(str(self.url), timeout=(self.collector_config.period - 1), followRedirect=False).addCallbacks(callback=self.success_callback, errback=self.error_callback, callbackArgs=[input_queue], errbackArgs=[input_queue])

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