linter fixes

Author: miguelgrinberg

elasticsearch/_async/helpers.py

@@ -93,6 +93,8 @@ async def _chunk_actions(
         chunk_size=chunk_size, max_chunk_bytes=max_chunk_bytes, serializer=serializer
     )
 
+    action: _TYPE_BULK_ACTION_WITH_META
+    data: _TYPE_BULK_ACTION_BODY
     if not flush_after_seconds:
         async for action, data in actions:
             ret = chunker.feed(action, data)
@@ -115,8 +117,8 @@ async def get_items() -> None:
 
             timeout: Optional[float] = flush_after_seconds
             while True:
-                action: _TYPE_BULK_ACTION_WITH_META = {}
-                data: _TYPE_BULK_ACTION_BODY = None
+                action = {}
+                data = None
                 with move_on_after(timeout) as scope:
                     action, data = await receiver.receive()
                     timeout = flush_after_seconds

elasticsearch/compat.py

@@ -15,14 +15,13 @@
 #  specific language governing permissions and limitations
 #  under the License.
 
-import asyncio
 import inspect
 import os
 import sys
-from contextlib import asynccontextmanager, contextmanager
+from contextlib import contextmanager
 from pathlib import Path
 from threading import Thread
-from typing import Any, AsyncIterator, Callable, Coroutine, Iterator, Tuple, Type, Union
+from typing import Any, Callable, Iterator, Tuple, Type, Union
 
 string_types: Tuple[Type[str], Type[bytes]] = (str, bytes)