exceptions.py

aioelasticsearch/__init__.py

@@ -1,14 +1,14 @@
 import asyncio
 
 from elasticsearch import Elasticsearch as _Elasticsearch  # isort:skip
-from elasticsearch.exceptions import *  # noqa # isort:skip
 
 from elasticsearch.connection_pool import (  # noqa # isort:skip
     ConnectionSelector, RoundRobinSelector,
 )
 from elasticsearch.serializer import JSONSerializer  # noqa # isort:skip
 
 from .compat import PY_350  # isort:skip
+from .exceptions import *  # noqa # isort:skip
 from .pool import AIOHttpConnectionPool  # noqa # isort:skip
 from .transport import AIOHttpTransport  # isort:skip
 

aioelasticsearch/connection.py

@@ -9,9 +9,9 @@
 else:
     from aiohttp.errors import ClientError
 
+from .exceptions import ConnectionError, ConnectionTimeout, SSLError  # noqa # isort:skip
+
 from elasticsearch.connection import Connection  # noqa # isort:skip
-from elasticsearch.exceptions import (ConnectionError, ConnectionTimeout,  # noqa # isort:skip
-                                      SSLError)
 from yarl import URL  # noqa # isort:skip
 
 

aioelasticsearch/exceptions.py

@@ -0,0 +1 @@
+from elasticsearch.exceptions import *  # noqa

aioelasticsearch/pool.py

@@ -4,9 +4,9 @@
 import random
 
 from elasticsearch.connection_pool import ConnectionSelector
-from elasticsearch.exceptions import ImproperlyConfigured
 
 from .compat import create_future
+from .exceptions import ImproperlyConfigured
 
 logger = logging.getLogger('elasticsearch')
 

aioelasticsearch/transport.py

@@ -2,14 +2,14 @@
 import logging
 from itertools import chain
 
-from elasticsearch.exceptions import (ConnectionError, ConnectionTimeout,
-                                      SerializationError, TransportError)
 from elasticsearch.serializer import (DEFAULT_SERIALIZERS, Deserializer,
                                       JSONSerializer)
 from elasticsearch.transport import Transport, get_host_info
 
 from .compat import ensure_future
 from .connection import AIOHttpConnection
+from .exceptions import (ConnectionError, ConnectionTimeout,
+                         SerializationError, TransportError)
 from .pool import AIOHttpConnectionPool, DummyConnectionPool
 
 logger = logging.getLogger('elasticsearch')