@@ -127,6 +127,7 @@ def __check_global_keys(client, global_keys):
127
127
Returns:
128
128
True if global keys are available, False if not
129
129
"""
130
+ query_keys = [str (x ) for x in global_keys ]
130
131
# Create a query job to get data row IDs given global keys
131
132
query_str_1 = """query get_datarow_with_global_key($global_keys:[ID!]!){dataRowsForGlobalKeys(where:{ids:$global_keys}){jobId}}"""
132
133
query_job_id = client .execute (query_str_1 , {"global_keys" :global_keys })['dataRowsForGlobalKeys' ]['jobId' ]
@@ -135,7 +136,7 @@ def __check_global_keys(client, global_keys):
135
136
accessDeniedGlobalKeys\n deletedDataRowGlobalKeys\n fetchedDataRows{id}\n notFoundGlobalKeys}jobStatus}}"""
136
137
res = client .execute (query_str_2 , {"job_id" :query_job_id })['dataRowsForGlobalKeysResult' ]['data' ]
137
138
return res
138
- global_keys_list = [ str ( x ) for x in global_key_to_upload_dict .keys ()]
139
+ global_keys_list = list ( global_key_to_upload_dict .keys ())
139
140
payload = __check_global_keys (client , global_keys_list )
140
141
loop_counter = 0
141
142
while len (payload ['notFoundGlobalKeys' ]) != len (global_keys_list ):
@@ -157,7 +158,7 @@ def __check_global_keys(client, global_keys):
157
158
new_global_key = f"{ global_key } _{ loop_counter } "
158
159
new_upload_dict ['global_key' ] = new_global_key
159
160
global_key_to_upload_dict [new_global_key ] = new_upload_dict
160
- global_keys_list = [ str ( x ) for x in global_key_to_upload_dict .keys ()]
161
+ global_keys_list = list ( global_key_to_upload_dict .keys ())
161
162
payload = __check_global_keys (client , global_keys_list )
162
163
upload_list = list (global_key_to_upload_dict .values ())
163
164
upload_results = []
0 commit comments