File tree Expand file tree Collapse file tree 3 files changed +6
-4
lines changed
aws-event-stream/src/aws_event_stream
aws-sdk-signers/src/aws_sdk_signers Expand file tree Collapse file tree 3 files changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -70,11 +70,13 @@ async def send(self, event: E) -> None:
7070 )
7171 if self ._signer is not None :
7272 encoder = self ._serializer .event_header_encoder_cls
73- result = await self ._signer .sign_event (
73+ result = await self ._signer .sign_event ( # type: ignore
7474 event_message = result ,
7575 event_encoder_cls = encoder ,
7676 )
77- encoded_result = result .encode ()
77+
78+ assert isinstance (result , EventMessage )
79+ encoded_result : bytes = result .encode ()
7880 try :
7981 await self ._writer .write (encoded_result )
8082 except Exception as e :
Original file line number Diff line number Diff line change @@ -387,7 +387,7 @@ def get_result(self) -> bytes:
387387 raise InvalidHeadersLength (len (result ))
388388 return result
389389
390- def encode_headers (self , headers : HEADERS_DICT ):
390+ def encode_headers (self , headers : HEADERS_DICT ) -> None :
391391 """Encode a map of headers.
392392
393393 :param headers: A mapping of headers to encode.
Original file line number Diff line number Diff line change @@ -833,7 +833,7 @@ async def sign_event(
833833 )
834834
835835 timestamp = new_signing_properties ["date" ]
836- headers : dict [str , str | bytes ] = {":date" : date_obj }
836+ headers : dict [str , str | bytes | datetime . datetime ] = {":date" : date_obj }
837837 encoder = event_encoder_cls ()
838838 encoder .encode_headers (headers )
839839 encoded_headers = encoder .get_result ()
You can’t perform that action at this time.
0 commit comments