From c0251239f33d770df14112a199097a216d29c0d4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?St=C3=A9phane=20Brunner?= Date: Mon, 24 Jun 2024 13:20:32 +0200 Subject: [PATCH] Remove unworking info --- github_app_geo_project/scripts/process_queue.py | 7 ------- 1 file changed, 7 deletions(-) diff --git a/github_app_geo_project/scripts/process_queue.py b/github_app_geo_project/scripts/process_queue.py index 830a52c9d78..aec3a2a7c1d 100644 --- a/github_app_geo_project/scripts/process_queue.py +++ b/github_app_geo_project/scripts/process_queue.py @@ -34,7 +34,6 @@ _LOGGER_WSGI = logging.getLogger("prometheus_client.wsgi") _NB_JOBS = Gauge("ghci_jobs_number", "Number of jobs", ["status"]) -_JOBS = Info("ghci_jobs", "Running jobs") class _JobInfo(NamedTuple): @@ -810,25 +809,19 @@ def _watch(self) -> None: _NB_JOBS.labels(status.name).set( session.query(models.Queue).filter(models.Queue.status == status).count() ) - info = {} text = [] for id_, job in _RUNNING_JOBS.items(): text.append( f"{id_}: {job.module} {job.event_name} {job.repository} [{job.priority}] (Worker max priority {job.worker_max_priority})" ) - info[f"job-id-{id_}"] = ( - f"{job.module} {job.event_name} {job.repository} [{job.priority}] (Worker max priority {job.worker_max_priority})" - ) try: for task in asyncio.all_tasks(): txt = io.StringIO() task.print_stack(file=txt) text.append("-" * 30) text.append(txt.getvalue()) - info[f"task-{id(task)}"] = txt.getvalue() except RuntimeError as exception: text.append(str(exception)) - _JOBS.info(info) if time.time() - self.last_run > 300: error_message = ["Old Status"]