You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by ke...@apache.org on 2022/10/01 08:13:24 UTC
[skywalking-python] branch master updated: style: deal with B026 reported by flake8 (#239)
This is an automated email from the ASF dual-hosted git repository.
kezhenxu94 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking-python.git
The following commit(s) were added to refs/heads/master by this push:
new 50d02ce style: deal with B026 reported by flake8 (#239)
50d02ce is described below
commit 50d02ce42c0781e2d86868da5df79a8eaf18c32d
Author: jiang1997 <ji...@live.cn>
AuthorDate: Sat Oct 1 16:13:20 2022 +0800
style: deal with B026 reported by flake8 (#239)
---
skywalking/plugins/sw_amqp.py | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/skywalking/plugins/sw_amqp.py b/skywalking/plugins/sw_amqp.py
index 7aab5e6..2eea3fd 100644
--- a/skywalking/plugins/sw_amqp.py
+++ b/skywalking/plugins/sw_amqp.py
@@ -55,7 +55,8 @@ def install():
def _sw_basic_consume(self, queue='', consumer_tag='', no_local=False,
no_ack=False, exclusive=False, nowait=False,
- callback=None, *args, **kwargs):
+ callback=None, arguments=None, on_cancel=None,
+ argsig='BssbbbbF'):
def _callback(msg):
peer = getattr(self.connection, 'host', '<unavailable>')
delivery_info = getattr(msg, 'delivery_info', {})
@@ -81,7 +82,8 @@ def install():
return callback(msg)
return _basic_consume(self, queue=queue, consumer_tag=consumer_tag, no_local=no_local, no_ack=no_ack,
- exclusive=exclusive, nowait=nowait, callback=_callback, *args, **kwargs)
+ exclusive=exclusive, nowait=nowait, callback=_callback, arguments=arguments,
+ on_cancel=on_cancel, argsig=argsig)
_basic_publish = Channel.basic_publish
_basic_consume = Channel.basic_consume