1717import ctypes
1818import logging
1919from dataclasses import dataclass , field
20- from typing import Callable , Dict , Literal , Optional , cast , Mapping
20+ from typing import Callable , Dict , Literal , Optional , cast , Mapping , Any
2121
2222from .event_emitter import EventEmitter
2323from ._ffi_client import FfiClient , FfiHandle
@@ -753,8 +753,8 @@ def _handle_stream_header(
753753
754754 text_reader = TextStreamReader (header )
755755 self ._text_stream_readers [header .stream_id ] = text_reader
756- task = asyncio .create_task (
757- text_stream_handler (text_reader , participant_identity )
756+ task : asyncio . Task [ Any ] = asyncio .create_task (
757+ text_stream_handler (text_reader , participant_identity ) # type: ignore
758758 )
759759 self ._data_stream_tasks .add (task )
760760 task .add_done_callback (self ._data_stream_tasks .discard )
@@ -769,8 +769,8 @@ def _handle_stream_header(
769769
770770 byte_reader = ByteStreamReader (header )
771771 self ._byte_stream_readers [header .stream_id ] = byte_reader
772- task = asyncio .create_task (
773- byte_stream_handler (byte_reader , participant_identity )
772+ task : asyncio . Task [ Any ] = asyncio .create_task (
773+ byte_stream_handler (byte_reader , participant_identity ) # type: ignore
774774 )
775775 self ._data_stream_tasks .add (task )
776776 task .add_done_callback (self ._data_stream_tasks .discard )
0 commit comments