removes federated options from prometheus metrics collectors.

pull/3030/head
Kieran Prasch 2022-12-07 11:14:08 +00:00
parent 7e06261c83
commit e3cf5a0e4e
2 changed files with 23 additions and 23 deletions

View File

@ -113,12 +113,11 @@ class UrsulaInfoMetricsCollector(BaseMetricsCollector):
self.metrics["learning_status"].state('running' if self.ursula._learning_task.running else 'stopped')
self.metrics["known_nodes_gauge"].set(len(self.ursula.known_nodes))
if not self.ursula.federated_only:
decentralized_payload = {
"staking_provider_address": self.ursula.checksum_address,
"operator_address": self.ursula.operator_address,
}
base_payload.update(decentralized_payload)
decentralized_payload = {
"staking_provider_address": self.ursula.checksum_address,
"operator_address": self.ursula.operator_address,
}
base_payload.update(decentralized_payload)
self.metrics["host_info"].info(base_payload)

View File

@ -157,26 +157,27 @@ def create_metrics_collectors(ursula: "Ursula") -> List[MetricsCollector]:
"""Create collectors used to obtain metrics."""
collectors: List[MetricsCollector] = [UrsulaInfoMetricsCollector(ursula=ursula)]
if not ursula.federated_only:
# Blockchain prometheus
# TODO possible include information about payment
collectors.append(BlockchainMetricsCollector(eth_provider_uri=ursula.eth_provider_uri))
# Blockchain prometheus
# TODO possible include information about payment
collectors.append(
BlockchainMetricsCollector(eth_provider_uri=ursula.eth_provider_uri)
)
# Staking Provider prometheus
collectors.append(
StakingProviderMetricsCollector(
staking_provider_address=ursula.checksum_address,
contract_registry=ursula.registry,
)
# Staking Provider prometheus
collectors.append(
StakingProviderMetricsCollector(
staking_provider_address=ursula.checksum_address,
contract_registry=ursula.registry,
)
)
# Operator prometheus
collectors.append(
OperatorMetricsCollector(
domain=ursula.domain,
operator_address=ursula.operator_address,
contract_registry=ursula.registry,
)
# Operator prometheus
collectors.append(
OperatorMetricsCollector(
domain=ursula.domain,
operator_address=ursula.operator_address,
contract_registry=ursula.registry,
)
)
return collectors