Skip to content

Commit

Permalink
Merge branch 'main' into rominf-python3.13
Browse files Browse the repository at this point in the history
  • Loading branch information
auvipy authored Jul 15, 2024
2 parents d14fa66 + 6318df3 commit 454c235
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 4 deletions.
7 changes: 4 additions & 3 deletions kombu/transport/redis.py
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,8 @@


logger = get_logger('kombu.transport.redis')
crit, warn = logger.critical, logger.warning

crit, warning = logger.critical, logger.warning

DEFAULT_PORT = 6379
DEFAULT_DB = 0
Expand Down Expand Up @@ -939,8 +940,8 @@ def _receive_one(self, c):
try:
message = loads(bytes_to_str(payload['data']))
except (TypeError, ValueError):
warn('Cannot process event on channel %r: %s',
channel, repr(payload)[:4096], exc_info=1)
warning('Cannot process event on channel %r: %s',
channel, repr(payload)[:4096], exc_info=1)
raise Empty()
exchange = channel.split('/', 1)[0]
self.connection._deliver(
Expand Down
5 changes: 4 additions & 1 deletion requirements/extras/zstd.txt
Original file line number Diff line number Diff line change
@@ -1 +1,4 @@
zstandard ; python_version < "3.13"
zstandard==0.23.0; python_version < "3.13"



0 comments on commit 454c235

Please sign in to comment.