def METHOD_NAME(
    config: Dict[str, str],
    request,
    configured_catalogue: ConfiguredAirbyteCatalog,
    airbyte_message1: AirbyteMessage,
    airbyte_message2: AirbyteMessage,
    test_table_name: str,
):
    config = request.getfixturevalue(config)
    destination = DestinationSqlite()
    generator = destination.write(
        config=config, configured_catalog=configured_catalogue, input_messages=[airbyte_message1, airbyte_message2]
    )
    result = list(generator)
    assert len(result) == 0
    con = sqlite3.connect(config.get("destination_path"))
    with con:
        cursor = con.execute(
            f"SELECT _airbyte_ab_id, _airbyte_emitted_at, _airbyte_data FROM _airbyte_raw_{test_table_name} ORDER BY _airbyte_data"
        )
        result = cursor.fetchall()
    assert len(result) == 2
    assert result[0][2] == json.dumps(airbyte_message1.record.data)
    assert result[1][2] == json.dumps(airbyte_message2.record.data)