mirror of
https://github.com/django/daphne.git
synced 2025-07-10 16:02:18 +03:00
I like having a plus here.
This commit is contained in:
parent
447c2e77cc
commit
1869061fa2
|
@ -97,7 +97,7 @@ def enforce_ordering(func=None, slight=False):
|
||||||
# Bad ordering - warn if we're getting close to the limit
|
# Bad ordering - warn if we're getting close to the limit
|
||||||
if getattr(message, "__doomed__", False):
|
if getattr(message, "__doomed__", False):
|
||||||
warnings.warn(
|
warnings.warn(
|
||||||
"Enforce ordering consumer reached retry limit, message "
|
"Enforce ordering consumer reached retry limit, message " +
|
||||||
"being dropped. Did you decorate all protocol consumers correctly?"
|
"being dropped. Did you decorate all protocol consumers correctly?"
|
||||||
)
|
)
|
||||||
raise ConsumeLater()
|
raise ConsumeLater()
|
||||||
|
|
Loading…
Reference in New Issue
Block a user