in migration_toolkit/executors/create_table.py [0:0]
def execute_create_table(filepath: str, bigquery_client: bigquery.Client):
logger.debug(f"Executing create bigquery table. Filepath: {filepath}")
ddl = read(filepath)
logger.info(f"Running SQL query:\n{ddl}")
query_job = bigquery_client.query(ddl)
res = [r for r in query_job.result()]
logger.debug(f"Done. Result: {res}")