32
32
class SeaResultSetQueueFactory (ABC ):
33
33
@staticmethod
34
34
def build_queue (
35
- sea_result_data : ResultData ,
35
+ result_data : ResultData ,
36
36
manifest : ResultManifest ,
37
37
statement_id : str ,
38
38
ssl_options : Optional [SSLOptions ] = None ,
@@ -45,7 +45,7 @@ def build_queue(
45
45
Factory method to build a result set queue for SEA backend.
46
46
47
47
Args:
48
- sea_result_data (ResultData): Result data from SEA response
48
+ result_data (ResultData): Result data from SEA response
49
49
manifest (ResultManifest): Manifest from SEA response
50
50
statement_id (str): Statement ID for the query
51
51
description (List[List[Any]]): Column descriptions
@@ -59,7 +59,7 @@ def build_queue(
59
59
60
60
if manifest .format == ResultFormat .JSON_ARRAY .value :
61
61
# INLINE disposition with JSON_ARRAY format
62
- return JsonQueue (sea_result_data .data )
62
+ return JsonQueue (result_data .data )
63
63
elif manifest .format == ResultFormat .ARROW_STREAM .value :
64
64
# EXTERNAL_LINKS disposition
65
65
if not max_download_threads :
@@ -74,11 +74,13 @@ def build_queue(
74
74
raise ValueError (
75
75
"SEA client is required for EXTERNAL_LINKS disposition"
76
76
)
77
- if not manifest :
78
- raise ValueError ("Manifest is required for EXTERNAL_LINKS disposition" )
77
+ if not result_data .external_links :
78
+ raise ValueError (
79
+ "External links are required for EXTERNAL_LINKS disposition"
80
+ )
79
81
80
82
return SeaCloudFetchQueue (
81
- initial_links = sea_result_data .external_links ,
83
+ initial_links = result_data .external_links ,
82
84
max_download_threads = max_download_threads ,
83
85
ssl_options = ssl_options ,
84
86
sea_client = sea_client ,
@@ -125,7 +127,7 @@ def __init__(
125
127
statement_id : str ,
126
128
total_chunk_count : int ,
127
129
lz4_compressed : bool = False ,
128
- description : Optional [ List [Tuple ]] = None ,
130
+ description : List [Tuple ] = [] ,
129
131
):
130
132
"""
131
133
Initialize the SEA CloudFetchQueue.
0 commit comments