def execute_copy_rows()

in migration_toolkit/executors/copy_rows.py [0:0]

• 7 lines of code
• 2 McCabe index (conditional complexity)

def execute_copy_rows(filepath: str, bigquery_client: bigquery.Client):
  logger.debug(f"Executing copy rows. Filepath: {filepath}")
  sql = read(filepath)

  logger.info(f"Running SQL query:\n{sql}")
  query_job = bigquery_client.query(sql)
  res = [r for r in query_job.result()]
  logger.debug(f"Done. Result: {res}")