We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2c64e63 commit cd4cd65Copy full SHA for cd4cd65
warehouse/packaging/tasks.py
@@ -375,13 +375,17 @@ def sync_bigquery_release_files(request):
375
request.tm.commit()
376
request.tm.begin()
377
378
+ table_schemas = {
379
+ table_name: bq.get_table(table_name).schema for table_name in table_names
380
+ }
381
+
382
for missing_file in missing_files:
383
# Add the objects back into the new session
384
request.db.add(missing_file)
385
release_file = missing_file.file
386
387
for table_name in table_names:
- table_schema = bq.get_table(table_name).schema
388
+ table_schema = table_schemas[table_name]
389
390
# Using the schema to populate the data allows us to automatically
391
# set the values to their respective fields rather than assigning
0 commit comments