@@ -362,7 +362,7 @@ def stream_stderr_updates(
362362 if not execution_id :
363363 raise ValueError (f"Expected a non-empty value for `execution_id` but received { execution_id !r} " )
364364
365- default_headers = {'Accept' : 'text/event-stream' }
365+ default_headers : Headers = {'Accept' : 'text/event-stream' }
366366 merged_headers = default_headers if extra_headers is None else {** default_headers , ** extra_headers }
367367
368368 if merged_headers and merged_headers .get (RAW_RESPONSE_HEADER ):
@@ -446,7 +446,7 @@ def stream_stdout_updates(
446446 if not execution_id :
447447 raise ValueError (f"Expected a non-empty value for `execution_id` but received { execution_id !r} " )
448448
449- default_headers = {'Accept' : 'text/event-stream' }
449+ default_headers : Headers = {'Accept' : 'text/event-stream' }
450450 merged_headers = default_headers if extra_headers is None else {** default_headers , ** extra_headers }
451451
452452 if merged_headers and merged_headers .get (RAW_RESPONSE_HEADER ):
@@ -814,7 +814,7 @@ async def stream_stderr_updates(
814814 if not execution_id :
815815 raise ValueError (f"Expected a non-empty value for `execution_id` but received { execution_id !r} " )
816816
817- default_headers = {'Accept' : 'text/event-stream' }
817+ default_headers : Headers = {'Accept' : 'text/event-stream' }
818818 merged_headers = default_headers if extra_headers is None else {** default_headers , ** extra_headers }
819819
820820 if merged_headers and merged_headers .get (RAW_RESPONSE_HEADER ):
@@ -898,7 +898,7 @@ async def stream_stdout_updates(
898898 if not execution_id :
899899 raise ValueError (f"Expected a non-empty value for `execution_id` but received { execution_id !r} " )
900900
901- default_headers = {'Accept' : 'text/event-stream' }
901+ default_headers : Headers = {'Accept' : 'text/event-stream' }
902902 merged_headers = default_headers if extra_headers is None else {** default_headers , ** extra_headers }
903903
904904
0 commit comments