check_table operator

When to use the check_table operator

The check_table operator allows you add checks on table level. For example

  • Count the number of row

  • Sum of a column

  • Checks involving multiple columns

This operator is a wrapper around Airflow’s SQLTableCheckOperator to allow seamless integrations with SDK supported dataset like Astro tables.

Supported Checks

Supported checks are also explained here.

    imdb_movies = aql.load_file(
        File("https://raw.githubusercontent.com/astronomer/astro-sdk/main/python-sdk/tests/data/homes.csv"),
        output_table=Table(conn_id="sqlite_default"),
    )
    aql.check_table(
        dataset=imdb_movies,
        checks={
            "sell_list": {"check_statement": "sell <= list"},
            "row_count": {"check_statement": "Count(*) == 47"},
        },
    )