add black lint
@@ -74,10 +74,12 @@ class DuckDBLinker(Linker):
super().__init__(settings_dict, input_tables, set_up_basic_logging)
if output_schema:
- self.con.execute(f"""
+ self.con.execute(
+ f"""
CREATE SCHEMA IF NOT EXISTS {output_schema};
SET schema '{output_schema}';
- """)
+ """
+ )
def _df_as_obj(self, templated_name, physical_name):
return DuckDBLinkerDataFrame(templated_name, physical_name, self)
@@ -93,9 +95,11 @@ class DuckDBLinker(Linker):
if transpile:
sql = sqlglot.transpile(sql, read="spark", write="duckdb", pretty=True)[0]
- logger.debug(execute_sql_logging_message_info(
- templated_name,
- self._prepend_schema_to_table_name(physical_name)))
+ logger.debug(
+ execute_sql_logging_message_info(
+ templated_name, self._prepend_schema_to_table_name(physical_name)
+ )
+ )
logger.log(5, log_sql(sql))
sql = f"""
