

def __init__(self, collector_config, task):
    self.collector_config = collector_config
    self.task = task
    self.url = ('http://%s:%d%s' % (task.host, task.port, self.collector_config.config.get(task.job.cluster.service.name, 'metric_url')))
    self.need_analyze = collector_config.services[task.job.cluster.service.name].need_analyze

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