def METHOD_NAME(config: Dict[str, str], test_table_name: str):
    yield
    with establish_connection(config, MagicMock()) as connection:
        with connection.cursor() as cursor:
            cursor.execute(f"DROP TABLE IF EXISTS _airbyte_raw_{test_table_name}")
            cursor.execute(f"DROP TABLE IF EXISTS ex_airbyte_raw_{test_table_name}")