Pass --use_cloud_function to get_schema_from_table (#3442)

This commit is contained in:
Anna Scholtz 2022-12-08 16:45:30 -08:00 коммит произвёл GitHub
Родитель 49fb0d5fb3
Коммит cd48f7c09c
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 4AEE18F83AFDEB23
2 изменённых файлов: 10 добавлений и 3 удалений

Просмотреть файл

@ -1482,7 +1482,11 @@ def _update_query_schema(
pass
table_schema = Schema.for_table(
project_name, dataset_name, table_name, partitioned_by
project_name,
dataset_name,
table_name,
partitioned_by,
use_cloud_function=use_cloud_function,
)
changed = True

Просмотреть файл

@ -57,7 +57,7 @@ class Schema:
return cls(json_schema)
@classmethod
def for_table(cls, project, dataset, table, partitioned_by=None):
def for_table(cls, project, dataset, table, partitioned_by=None, *args, **kwargs):
"""Get the schema for a BigQuery table."""
query = f"SELECT * FROM `{project}.{dataset}.{table}`"
@ -67,7 +67,10 @@ class Schema:
try:
return cls(
dryrun.DryRun(
os.path.join(project, dataset, table, "query.sql"), query
os.path.join(project, dataset, table, "query.sql"),
query,
*args,
**kwargs,
).get_schema()
)
except Exception as e: