Compare commits

..

No commits in common. "5582a0a29b584d6806340e77a3fec8a110868624" and "b291caac46e710c96e8343b611fce83e4065530c" have entirely different histories.

2 changed files with 10 additions and 14 deletions

View file

@ -480,11 +480,11 @@
] ]
}, },
"locked": { "locked": {
"lastModified": 1727799384, "lastModified": 1724616313,
"narHash": "sha256-TRxR6zELQoUDPhLkmBU8QjgskNyVcblKgQIxhuOyNRc=", "narHash": "sha256-9syppf9Gm/6F4wQQAbsf7rGY1DooMsprnsEY/0eaewg=",
"ref": "refs/heads/main", "ref": "refs/heads/main",
"rev": "d3257e4761370a44ad8ae883de3ff67ddac4b736", "rev": "44b9a7b95d23e7a8587cb963f00382046707f2db",
"revCount": 4215, "revCount": 4202,
"type": "git", "type": "git",
"url": "https://git.lix.systems/lix-project/hydra.git" "url": "https://git.lix.systems/lix-project/hydra.git"
}, },
@ -505,11 +505,11 @@
"pre-commit-hooks": "pre-commit-hooks" "pre-commit-hooks": "pre-commit-hooks"
}, },
"locked": { "locked": {
"lastModified": 1725228396, "lastModified": 1723919517,
"narHash": "sha256-QBXwqyPuHUKBiuyzHBxqH/MpjPY9DQiY2M81P2t6b/0=", "narHash": "sha256-D6+zmRXzr85p7riphuIrJQqangoJe70XM5jHhMWwXws=",
"ref": "refs/heads/main", "ref": "refs/heads/main",
"rev": "02eb07cfd539c34c080cb1baf042e5e780c1fcc2", "rev": "278fddc317cf0cf4d3602d0ec0f24d1dd281fadb",
"revCount": 16214, "revCount": 16138,
"type": "git", "type": "git",
"url": "https://git.lix.systems/lix-project/lix" "url": "https://git.lix.systems/lix-project/lix"
}, },

View file

@ -22,9 +22,6 @@ 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"
) )
@ -233,7 +230,6 @@ 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"])
@ -338,11 +334,11 @@ async def update_metrics_loop(hydra_url, scrape_interval):
) )
update_metrics(response.json()) update_metrics(response.json())
await asyncio.sleep(scrape_interval)
except Exception as ex: except Exception as ex:
logging.exception("Failed to update metrics", exc_info=ex) logging.exception("Failed to update metrics", exc_info=ex)
await asyncio.sleep(scrape_interval)
@click.command() @click.command()
@click.option("--hydra-url", default="https://hydra.forkos.org/") @click.option("--hydra-url", default="https://hydra.forkos.org/")