def METHOD_NAME(
    config: Dict[str, str],
    create_test_data: Generator[Connection, None, None],
    test_table_name: str,
    configured_catalogue: ConfiguredAirbyteCatalog,
):
    expected_data = [
        {"column2": 221, "column3": "2021-01-01", "column4": "2021-01-01T12:00:01", "column6": [1, 2, 3], "column7": 1},
        {
            "column3": "2021-01-02",
            "column4": "2021-01-02T12:00:02",
            # If column5 check fails you mignt not have the latest Firebolt version
            # with Decimal data type enabled
            "column5": "1231232.1234599999904570548442587065362",
            "column6": [1, 2, 3],
        },
    ]
    source = SourceFirebolt()
    result = source.read(logger=MagicMock(), config=config, catalog=configured_catalogue, state={})
    data = list(result)
    assert all([x.record.stream == test_table_name for x in data]), "Table name is incorrect"
    assert [x.record.data for x in data] == expected_data, "Test data is not matching"