Function run_sql

scripts/_sdk_sql.py:33–41

(workspace: WorkspaceClient, warehouse_id: str, sql: str)

def run_sql(workspace: WorkspaceClient, warehouse_id: str, sql: str) -> None:
    print(f"  Running: {sql}")
    result = workspace.statement_execution.execute_statement(
        warehouse_id=warehouse_id,
        statement=sql,
        wait_timeout="50s",
    )
    if result.status.state != StatementState.SUCCEEDED:
        raise RuntimeError(f"Statement failed ({result.status.state}): {result.status.error}")