summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorOmer Katz <omer.drow@gmail.com>2017-12-17 12:15:42 +0200
committerOmer Katz <omer.drow@gmail.com>2017-12-17 12:15:42 +0200
commit3a7cdb07c9bf75b54282274d711af15ca6ad5d9f (patch)
treeb4b5a3aa64a7bf9ccf139a0bf74af11f9db73cb9
parent6fb1f33de46be837d835b0d511957ebc3011fb37 (diff)
downloadkombu-3a7cdb07c9bf75b54282274d711af15ca6ad5d9f.tar.gz
Make flake8 happy.
-rw-r--r--kombu/transport/SLMQ.py8
-rw-r--r--kombu/utils/debug.py8
-rw-r--r--t/unit/test_log.py18
-rw-r--r--t/unit/utils/test_encoding.py4
4 files changed, 19 insertions, 19 deletions
diff --git a/kombu/transport/SLMQ.py b/kombu/transport/SLMQ.py
index 3b0689b3..5848f720 100644
--- a/kombu/transport/SLMQ.py
+++ b/kombu/transport/SLMQ.py
@@ -119,12 +119,12 @@ class Channel(virtual.Channel):
"""Delete all current messages in a queue."""
q = self._new_queue(queue)
n = 0
- l = q.pop(10)
- while l['items']:
- for m in l['items']:
+ results = q.pop(10)
+ while results['items']:
+ for m in results['items']:
self.delete_message(queue, m['id'])
n += 1
- l = q.pop(10)
+ results = q.pop(10)
return n
def delete_message(self, queue, message_id):
diff --git a/kombu/utils/debug.py b/kombu/utils/debug.py
index f52f8f39..e513b8c8 100644
--- a/kombu/utils/debug.py
+++ b/kombu/utils/debug.py
@@ -14,10 +14,10 @@ __all__ = ['setup_logging', 'Logwrapped']
def setup_logging(loglevel=logging.DEBUG, loggers=['kombu.connection',
'kombu.channel']):
"""Setup logging to stdout."""
- for logger in loggers:
- l = get_logger(logger)
- l.addHandler(logging.StreamHandler())
- l.setLevel(loglevel)
+ for logger_name in loggers:
+ logger = get_logger(logger_name)
+ logger.addHandler(logging.StreamHandler())
+ logger.setLevel(loglevel)
@python_2_unicode_compatible
diff --git a/t/unit/test_log.py b/t/unit/test_log.py
index 5946755b..772b520d 100644
--- a/t/unit/test_log.py
+++ b/t/unit/test_log.py
@@ -18,24 +18,24 @@ from kombu.log import (
class test_get_logger:
def test_when_string(self):
- l = get_logger('foo')
+ logger = get_logger('foo')
- assert l is logging.getLogger('foo')
- h1 = l.handlers[0]
+ assert logger is logging.getLogger('foo')
+ h1 = logger.handlers[0]
assert isinstance(h1, logging.NullHandler)
def test_when_logger(self):
- l = get_logger(logging.getLogger('foo'))
- h1 = l.handlers[0]
+ logger = get_logger(logging.getLogger('foo'))
+ h1 = logger.handlers[0]
assert isinstance(h1, logging.NullHandler)
def test_with_custom_handler(self):
- l = logging.getLogger('bar')
+ logger = logging.getLogger('bar')
handler = logging.NullHandler()
- l.addHandler(handler)
+ logger.addHandler(handler)
- l = get_logger('bar')
- assert l.handlers[0] is handler
+ logger = get_logger('bar')
+ assert logger.handlers[0] is handler
def test_get_loglevel(self):
assert get_loglevel('DEBUG') == logging.DEBUG
diff --git a/t/unit/utils/test_encoding.py b/t/unit/utils/test_encoding.py
index e3d1040a..a3d6bdc8 100644
--- a/t/unit/utils/test_encoding.py
+++ b/t/unit/utils/test_encoding.py
@@ -97,9 +97,9 @@ class test_safe_str:
def test_when_unrepresentable(self):
- class O(object):
+ class UnrepresentableObject(object):
def __repr__(self):
raise KeyError('foo')
- assert '<Unrepresentable' in safe_str(O())
+ assert '<Unrepresentable' in safe_str(UnrepresentableObject())