Skip to content

Commit ab2aa1f

Browse files
Merge pull request #753 from Bogdanp/enqueue-signals-doc
Document before/after_enqueue signals as including retries
2 parents c1bf825 + a22a6c5 commit ab2aa1f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

dramatiq/middleware/middleware.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -90,10 +90,10 @@ def after_declare_delay_queue(self, broker: Broker, queue_name: str) -> None:
9090
"""Called after a delay queue has been declared."""
9191

9292
def before_enqueue(self, broker: Broker, message: Message, delay: int) -> None:
93-
"""Called before a message is enqueued."""
93+
"""Called before a message is enqueued (including retries)."""
9494

9595
def after_enqueue(self, broker: Broker, message: Message, delay: int) -> None:
96-
"""Called after a message has been enqueued."""
96+
"""Called after a message has been enqueued (including retries)."""
9797

9898
def before_delay_message(self, broker: Broker, message: MessageProxy) -> None:
9999
"""Called before a message has been delayed in worker memory."""

0 commit comments

Comments
 (0)