@@ -71,7 +71,7 @@ def __init__(
7171 content_type : Optional [str ] = None ,
7272 chunk_size : Optional [int ] = None ,
7373 deadline : Optional [datetime .datetime ] = None ,
74- headers : Optional [Sequence [Tuple [str , Union [ str , bytes ] ]]] = None ,
74+ headers : Optional [Sequence [Tuple [str , str ]]] = None ,
7575 on_progress : Optional [Callable [[ResumableUploadStatus ], None ]] = None ,
7676 ):
7777 """Initializes the RequestsResumableUpload.
@@ -96,10 +96,7 @@ def __init__(
9696 self .size = size
9797 self .content_type = content_type
9898 self .deadline = deadline
99- self .extra_headers = {
100- k : v .decode ("utf-8" ) if isinstance (v , bytes ) else v
101- for k , v in (headers or [])
102- }
99+ self .extra_headers = headers
103100 self .on_progress = on_progress
104101
105102 if hasattr (stream , "tell" ):
@@ -435,7 +432,7 @@ def make_resumable_upload(
435432 chunk_size : Optional [int ] = None ,
436433 request_retry : Optional [google .api_core .retry .Retry ] = None ,
437434 deadline : Optional [datetime .datetime ] = None ,
438- headers : Optional [Sequence [Tuple [str , Union [ str , bytes ] ]]] = None ,
435+ headers : Optional [Sequence [Tuple [str , str ]]] = None ,
439436 on_progress : Optional [Callable [[ResumableUploadStatus ], None ]] = None ,
440437) -> requests .Response :
441438 """Makes a resumable upload using synchronous I/O.
@@ -456,6 +453,7 @@ def make_resumable_upload(
456453 Returns:
457454 The final requests.Response object.
458455 """
456+
459457 upload = RequestsResumableUpload (
460458 upload_url = upload_url ,
461459 stream = stream ,
0 commit comments