diff --git a/dbt/adapters/bigquery/impl.py b/dbt/adapters/bigquery/impl.py index 69f32e9a1..c7957e341 100644 --- a/dbt/adapters/bigquery/impl.py +++ b/dbt/adapters/bigquery/impl.py @@ -611,7 +611,9 @@ def alter_table_add_columns(self, relation, columns): client.update_table(new_table, ["schema"]) @available.parse_none - def load_dataframe(self, database, schema, table_name, agate_table, column_override, kms_key_name): + def load_dataframe( + self, database, schema, table_name, agate_table, column_override, kms_key_name + ): bq_schema = self._agate_to_schema(agate_table, column_override) conn = self.connections.get_thread_connection() client = conn.handle