File tree Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -133,7 +133,6 @@ class CloudFetchQueue(ResultSetQueue, ABC):
133
133
134
134
def __init__ (
135
135
self ,
136
- schema_bytes : bytes ,
137
136
max_download_threads : int ,
138
137
ssl_options : SSLOptions ,
139
138
lz4_compressed : bool = True ,
@@ -149,7 +148,6 @@ def __init__(
149
148
lz4_compressed: Whether the data is LZ4 compressed
150
149
description: Column descriptions
151
150
"""
152
- self .schema_bytes = schema_bytes
153
151
self .lz4_compressed = lz4_compressed
154
152
self .description = description
155
153
self ._ssl_options = ssl_options
@@ -422,13 +420,13 @@ def __init__(
422
420
description: Hive table schema description
423
421
"""
424
422
super ().__init__ (
425
- schema_bytes = schema_bytes ,
426
423
max_download_threads = max_download_threads ,
427
424
ssl_options = ssl_options ,
428
425
lz4_compressed = lz4_compressed ,
429
426
description = description ,
430
427
)
431
428
429
+ self .schema_bytes = schema_bytes
432
430
self .start_row_index = start_row_offset
433
431
self .result_links = result_links or []
434
432
You can’t perform that action at this time.
0 commit comments