def METHOD_NAME(expectation_suite):
    flow = PrefectLogs(
        name="Extract prefect data test",
        query="""
                {
                        project {
                            id
                            name
                            flows (
                                where : {name: {_eq: "1-raw google_analytics_oso_sps_gb extract"}}
                            ) {
                                    id
                                    name
                                    version
                                    flow_runs(
                                        order_by: {end_time: desc}
                                        where: {_and:
                                            [
                                            {scheduled_start_time:{ %s: "%s" }},
                                            {state: {_neq: "Scheduled"}}
                                            ]
                                        }
                                        )
                                            {
                                            id
                                            scheduled_start_time
                                            start_time
                                            end_time
                                            state
                                            created_by_user_id
                                            }
                            }
                        }
                    }
        """,
        scheduled_start_time="2022-09-05",
        filter_type="_gte",
        local_file_path=f"prefect_extract_logs.parquet",
        adls_path=f"raw/supermetrics/mp/prefect_extract_logs.parquet",
    )
    results = flow.run()
    assert results.is_successful()