diff options
| author | Omer Katz <omer.drow@gmail.com> | 2020-08-04 17:27:37 +0300 |
|---|---|---|
| committer | Omer Katz <omer.drow@gmail.com> | 2020-08-04 17:37:29 +0300 |
| commit | 85578afc4fea28adc16afdd3d7418b240357d96e (patch) | |
| tree | 81f7b78cc160aadba8eec61babc5a79b2f42a612 /kombu/utils | |
| parent | a130c4636796623aa038848202b02c1a549c1312 (diff) | |
| download | kombu-remove-python2-support.tar.gz | |
autopep8.remove-python2-support
Diffstat (limited to 'kombu/utils')
| -rw-r--r-- | kombu/utils/eventio.py | 5 | ||||
| -rw-r--r-- | kombu/utils/scheduling.py | 2 | ||||
| -rw-r--r-- | kombu/utils/url.py | 2 |
3 files changed, 4 insertions, 5 deletions
diff --git a/kombu/utils/eventio.py b/kombu/utils/eventio.py index d6149f7e..fa7533d4 100644 --- a/kombu/utils/eventio.py +++ b/kombu/utils/eventio.py @@ -3,7 +3,6 @@ import errno import math import select as __select__ -import socket import sys from numbers import Integral @@ -132,8 +131,8 @@ class _kqueue: kevents = [] if events & WRITE: kevents.append(kevent(fd, - filter=KQ_FILTER_WRITE, - flags=flags)) + filter=KQ_FILTER_WRITE, + flags=flags)) if not kevents or events & READ: kevents.append( kevent(fd, filter=KQ_FILTER_READ, flags=flags), diff --git a/kombu/utils/scheduling.py b/kombu/utils/scheduling.py index be663e2e..1875fce4 100644 --- a/kombu/utils/scheduling.py +++ b/kombu/utils/scheduling.py @@ -57,7 +57,6 @@ class FairCycle: def close(self): """Close cycle.""" - pass def __repr__(self): """``repr(cycle)``.""" @@ -94,7 +93,6 @@ class priority_cycle(round_robin_cycle): def rotate(self, last_used): """Unused in this implementation.""" - pass class sorted_cycle(priority_cycle): diff --git a/kombu/utils/url.py b/kombu/utils/url.py index ec2fb3e8..0d35722a 100644 --- a/kombu/utils/url.py +++ b/kombu/utils/url.py @@ -79,6 +79,8 @@ def url_to_parts(url): unquote(path or '') or None, dict(parse_qsl(parts.query)), ) + + _parse_url = url_to_parts # noqa |