in dbt/adapters/maxcompute/impl.py [0:0]
def run_raw_sql(self, sql: str, configs: Any) -> None:
hints = {}
default_schema = None
if configs is not None:
default_schema = configs.get("schema")
if default_schema is not None:
client_schema = self.get_odps_client().schema
default_schema = f"{client_schema}_{default_schema.strip()}"
sql_hints = configs.get("sql_hints")
if sql_hints:
hints.update(sql_hints)
inst = self.get_odps_client().execute_sql(
sql=sql, hints=hints, default_schema=default_schema
)
logger.debug(f"Run raw sql: {sql}, instanceId: {inst.id}")