mirror of
https://github.com/django/daphne.git
synced 2025-06-29 01:13:16 +03:00
Fix line length
This commit is contained in:
parent
8fba5220d9
commit
447c2e77cc
|
@ -96,7 +96,10 @@ def enforce_ordering(func=None, slight=False):
|
||||||
else:
|
else:
|
||||||
# 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("Enforce ordering consumer reached retry limit, message being dropped. Did you decorate all protocol consumers correctly?")
|
warnings.warn(
|
||||||
|
"Enforce ordering consumer reached retry limit, message "
|
||||||
|
"being dropped. Did you decorate all protocol consumers correctly?"
|
||||||
|
)
|
||||||
raise ConsumeLater()
|
raise ConsumeLater()
|
||||||
return inner
|
return inner
|
||||||
if func is not None:
|
if func is not None:
|
||||||
|
|
Loading…
Reference in New Issue
Block a user