diff options
| author | Andreas Jaeger <aj@suse.com> | 2020-03-27 19:16:32 +0100 |
|---|---|---|
| committer | Andreas Jaeger <jaegerandi@gmail.com> | 2020-03-30 13:49:29 +0000 |
| commit | 7f638bb493571f2a6d30d3679945119d6596cfa7 (patch) | |
| tree | e348dc8e9eaf5f8e99cda8b222c8c704da025987 /oslo_messaging/_drivers/impl_rabbit.py | |
| parent | d87618b24fc9b11b5ae216e241e1a4d1d4fb8e72 (diff) | |
| download | oslo-messaging-7f638bb493571f2a6d30d3679945119d6596cfa7.tar.gz | |
Update hacking for Python312.1.0
The repo is Python 3 now, so update hacking to version 3.0 which
supports Python 3.
Update local hacking check for new flake8 version.
Blacklist:
W504 line break after binary operator
Fix:
E741 ambiguous variable name
E117 over-indented
E305 expected 2 blank lines after class or function definition, found 1
F841 local variable 'e' is assigned to but never used
W605 invalid escape sequence '\.'
Change-Id: I99d574ca6569f1f177d2c5ce1011f269f4343619
Diffstat (limited to 'oslo_messaging/_drivers/impl_rabbit.py')
| -rw-r--r-- | oslo_messaging/_drivers/impl_rabbit.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index 78c5f55..46c5ae0 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -146,7 +146,7 @@ rabbit_opts = [ 'queue. If you just want to make sure that all queues (except ' 'those with auto-generated names) are mirrored across all ' 'nodes, run: ' - """\"rabbitmqctl set_policy HA '^(?!amq\.).*' """ + """\"rabbitmqctl set_policy HA '^(?!amq\\.).*' """ """'{"ha-mode": "all"}' \""""), cfg.IntOpt('rabbit_transient_queues_ttl', min=1, @@ -192,7 +192,7 @@ def _get_queue_arguments(rabbit_ha_queues, rabbit_queue_ttl): no longer controlled by the x-ha-policy argument when declaring a queue. If you just want to make sure that all queues (except those with auto-generated names) are mirrored across all nodes, run: - rabbitmqctl set_policy HA '^(?!amq\.).*' '{"ha-mode": "all"}' + rabbitmqctl set_policy HA '^(?!amq\\.).*' '{"ha-mode": "all"}' If the rabbit_queue_ttl option is > 0, then the queue is declared with the "Queue TTL" value as described here: @@ -1204,8 +1204,8 @@ class Connection(object): """Publish a message.""" if not (exchange.passive or exchange.name in self._declared_exchanges): - exchange(self.channel).declare() - self._declared_exchanges.add(exchange.name) + exchange(self.channel).declare() + self._declared_exchanges.add(exchange.name) log_info = {'msg': msg, 'who': exchange or 'default', |