Move kafka.selectors34 to kafka.vendor.selectors34
This commit is contained in:
@@ -13,7 +13,7 @@ try:
|
|||||||
import selectors # pylint: disable=import-error
|
import selectors # pylint: disable=import-error
|
||||||
except ImportError:
|
except ImportError:
|
||||||
# vendored backport module
|
# vendored backport module
|
||||||
from . import selectors34 as selectors
|
from .vendor import selectors34 as selectors
|
||||||
|
|
||||||
import socket
|
import socket
|
||||||
import time
|
import time
|
||||||
|
0
kafka/vendor/__init__.py
vendored
Normal file
0
kafka/vendor/__init__.py
vendored
Normal file
@@ -3,7 +3,7 @@ try:
|
|||||||
import selectors # pylint: disable=import-error
|
import selectors # pylint: disable=import-error
|
||||||
except ImportError:
|
except ImportError:
|
||||||
# vendored backport module
|
# vendored backport module
|
||||||
import kafka.selectors34 as selectors
|
import kafka.vendor.selectors34 as selectors
|
||||||
|
|
||||||
import socket
|
import socket
|
||||||
import time
|
import time
|
||||||
|
Reference in New Issue
Block a user