kiaragrouwstra/infra
0
0
Fork 0
forked from the-distro/infra
Code Pull requests Activity

Add new metric to Hydra exporter

Browse source
This commit is contained in:
Ilya K 2024-10-01 19:27:05 +03:00
parent 98d899fabc
commit 4ddf87fa8e
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
services/monitoring/exporters/hydra/hydra-exporter.py
View file

@ -22,6 +22,9 @@ steps_building = Gauge("hydra_steps_building", "Number of steps currently buildi
steps_copying_to = Gauge( steps_copying_to = Gauge(
"hydra_steps_copying_to", "Number of steps copying inputs to a worker" "hydra_steps_copying_to", "Number of steps copying inputs to a worker"
) )
steps_waiting_for_download_slot = Gauge(
"hydra_steps_waiting_for_download_slot", "Number of steps waiting for download slot"
)
steps_copying_from = Gauge( steps_copying_from = Gauge(
"hydra_steps_copying_from", "Number of steps copying outputs from a worker" "hydra_steps_copying_from", "Number of steps copying outputs from a worker"
) )
@ -230,6 +233,7 @@ def update_metrics(status):
steps_active.set({}, status["nrActiveSteps"]) steps_active.set({}, status["nrActiveSteps"])
steps_building.set({}, status["nrStepsBuilding"]) steps_building.set({}, status["nrStepsBuilding"])
steps_copying_to.set({}, status["nrStepsCopyingTo"]) steps_copying_to.set({}, status["nrStepsCopyingTo"])
steps_waiting_for_download_slot.set({}, status["nrStepsWaitingForDownloadSlot"])
steps_copying_from.set({}, status["nrStepsCopyingFrom"]) steps_copying_from.set({}, status["nrStepsCopyingFrom"])
steps_waiting.set({}, status["nrStepsWaiting"]) steps_waiting.set({}, status["nrStepsWaiting"])
steps_unsupported.set({}, status["nrUnsupportedSteps"]) steps_unsupported.set({}, status["nrUnsupportedSteps"])