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