summaryrefslogtreecommitdiff
path: root/kombu/utils/eventio.py
diff options
context:
space:
mode:
authorOmer Katz <omer.drow@gmail.com>2020-08-04 17:27:37 +0300
committerOmer Katz <omer.drow@gmail.com>2020-08-04 17:37:29 +0300
commit85578afc4fea28adc16afdd3d7418b240357d96e (patch)
tree81f7b78cc160aadba8eec61babc5a79b2f42a612 /kombu/utils/eventio.py
parenta130c4636796623aa038848202b02c1a549c1312 (diff)
downloadkombu-remove-python2-support.tar.gz
Diffstat (limited to 'kombu/utils/eventio.py')
-rw-r--r--kombu/utils/eventio.py5
1 files changed, 2 insertions, 3 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),