From 951c24dab5de997c8c0e5b91ef55dfda2136ef6e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Simonyi=20Gerg=C5=91?= <28359278+gergosimonyi@users.noreply.github.com> Date: Mon, 4 Aug 2025 13:05:57 +0200 Subject: [PATCH] packages/django-dramatiq-postgres: fix typo (#15932) * fix typo * fix typo --- .../django_dramatiq_postgres/middleware.py | 18 +++++++++--------- website/docs/releases/2025/v2025.8.md | 6 +++--- 2 files changed, 12 insertions(+), 12 deletions(-) diff --git a/packages/django-dramatiq-postgres/django_dramatiq_postgres/middleware.py b/packages/django-dramatiq-postgres/django_dramatiq_postgres/middleware.py index e4dcba7b92..01df589213 100644 --- a/packages/django-dramatiq-postgres/django_dramatiq_postgres/middleware.py +++ b/packages/django-dramatiq-postgres/django_dramatiq_postgres/middleware.py @@ -186,19 +186,19 @@ class MetricsMiddleware(Middleware): "The total number of dead-lettered tasks.", self.labels, ) - self.inprogress_messages = Gauge( - f"{self.prefix}_tasks_inprogress", + self.in_progress_messages = Gauge( + f"{self.prefix}_tasks_in_progress", "The number of tasks in progress.", self.labels, multiprocess_mode="livesum", ) - self.inprogress_delayed_messages = Gauge( - f"{self.prefix}_tasks_delayed_inprogress", + self.in_progress_delayed_messages = Gauge( + f"{self.prefix}_tasks_delayed_in_progress", "The number of delayed tasks in memory.", self.labels, ) self.messages_durations = Histogram( - f"{self.prefix}_tasks_duration_miliseconds", + f"{self.prefix}_tasks_duration_milliseconds", "The time spent processing tasks.", self.labels, buckets=( @@ -244,15 +244,15 @@ class MetricsMiddleware(Middleware): def before_delay_message(self, broker: Broker, message: Message): self.delayed_messages.add(message.message_id) - self.inprogress_delayed_messages.labels(*self._make_labels(message)).inc() + self.in_progress_delayed_messages.labels(*self._make_labels(message)).inc() def before_process_message(self, broker: Broker, message: Message): labels = self._make_labels(message) if message.message_id in self.delayed_messages: self.delayed_messages.remove(message.message_id) - self.inprogress_delayed_messages.labels(*labels).dec() + self.in_progress_delayed_messages.labels(*labels).dec() - self.inprogress_messages.labels(*labels).inc() + self.in_progress_messages.labels(*labels).inc() self.message_start_times[message.message_id] = current_millis() def after_process_message( @@ -269,7 +269,7 @@ class MetricsMiddleware(Middleware): message_duration = current_millis() - message_start_time self.messages_durations.labels(*labels).observe(message_duration) - self.inprogress_messages.labels(*labels).dec() + self.in_progress_messages.labels(*labels).dec() self.total_messages.labels(*labels).inc() if exception is not None: self.total_errored_messages.labels(*labels).inc() diff --git a/website/docs/releases/2025/v2025.8.md b/website/docs/releases/2025/v2025.8.md index 1007f134ec..b90a97df80 100644 --- a/website/docs/releases/2025/v2025.8.md +++ b/website/docs/releases/2025/v2025.8.md @@ -50,9 +50,9 @@ Instead, the following metrics are now available: - `authentik_tasks_errors_total` - `authentik_tasks_retries_total` - `authentik_tasks_rejected_total` -- `authentik_tasks_inprogress` -- `authentik_tasks_delayed_inprogress` -- `authentik_tasks_duration_miliseconds` +- `authentik_tasks_in_progress` +- `authentik_tasks_delayed_in_progress` +- `authentik_tasks_duration_milliseconds` ## New features