From 2ca9edb1bc5855b63118294546e017dc2fce77e4 Mon Sep 17 00:00:00 2001 From: Marc 'risson' Schmitt Date: Wed, 18 Jun 2025 17:04:24 +0200 Subject: [PATCH] fixup Signed-off-by: Marc 'risson' Schmitt --- .../django-dramatiq-postgres/django_dramatiq_postgres/broker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/django-dramatiq-postgres/django_dramatiq_postgres/broker.py b/packages/django-dramatiq-postgres/django_dramatiq_postgres/broker.py index b9bdc4bf63..55146d079b 100644 --- a/packages/django-dramatiq-postgres/django_dramatiq_postgres/broker.py +++ b/packages/django-dramatiq-postgres/django_dramatiq_postgres/broker.py @@ -373,7 +373,7 @@ class _PostgresConsumer(Consumer): notify = self.notifies.pop(0) task = self.query_set.get(message_id=notify.payload) message = Message.decode(task.message) - message.task = task + message.options["task"] = task if self._consume_one(message): self.in_processing.add(message.message_id) return MessageProxy(message)