Function _run_sql

misc/python/materialize/cli/run.py:594–597

(conn: psycopg.Connection, sql: str)

def _run_sql(conn: psycopg.Connection, sql: str) -> None:
    print(f"> {sql}")
    with conn.cursor() as cur:
        cur.execute(sql.encode("utf-8"))


def _handle_lingering_services(kill: bool = False) -> None: