def execute_create_table()

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}")