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