def METHOD_NAME(sample_dag):
    @aql.dataframe
    def validate_result(df: pd.DataFrame):
        assert df.iloc[0].to_dict()["first_name"] == "PENELOPE"
    @aql.transform
    def sample_pg():
        return "SELECT * FROM actor WHERE last_name LIKE 'G%%'"
    with sample_dag:
        pg_df = sample_pg(conn_id="postgres_conn_pagila")
        validate_result(pg_df)
    test_utils.run_dag(sample_dag)