Merge pull request #683 from camptocamp/fix

Add tasks number in Prometheus
camptocamp · Jan 27, 2025 · d419105 · d419105
2 parents 087307d + 055aeac
commit d419105
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/github_app_geo_project/scripts/process_queue.py b/github_app_geo_project/scripts/process_queue.py
@@ -813,6 +813,10 @@ async def __call__(self, *args: Any, **kwds: Any) -> Any:
     def _watch(self) -> None:
         while True:
             _LOGGER.debug("Prometheus watch: alive")
+            try:
+                _NB_JOBS.labels("Tasks").set(len(asyncio.all_tasks()))
+            except RuntimeError:
+                pass
             with self.Session() as session:
                 for status in models.JobStatus:
                     _NB_JOBS.labels(status.name).set(