openstack/oslo.messaging
Code Issues Proposed changes

Replace LOG.warn

Browse Source 
The warn method is deprecated in favor of the warning method.

Change-Id: Iae80055c4ae15630aaeeb3cc71560060c1f0cab6
This commit is contained in:
Takashi Kajinami
2025-06-22 22:50:44 +09:00
parent 7b58539988
commit e50539bb5d
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
oslo_messaging/_drivers/impl_rabbit.py
View File

@ -455,8 +455,8 @@ class Consumer:
def reset_stream_offset(self):
if not self.rabbit_stream_fanout:
return
LOG.warn("Reset consumer for queue %s next offset was at %s.",
self.queue_name, self.next_stream_offset)
LOG.warning("Reset consumer for queue %s next offset was at %s.",
self.queue_name, self.next_stream_offset)
self.next_stream_offset = "last"
def declare(self, conn):
@ -1112,9 +1112,9 @@ class Connection:
# happen, for example, when we delete the stream queue.
# We need to start consuming from "last" because the stream
# offset maybe reset.
LOG.warn('[%s] Basic.cancel received. '
'Resetting consumers offsets to last.',
self.connection_id)
LOG.warning('[%s] Basic.cancel received. '
'Resetting consumers offsets to last.',
self.connection_id)
for consumer in self._consumers:
consumer.reset_stream_offset()