diff --git a/sdk/python/feast/infra/utils/snowflake_utils.py b/sdk/python/feast/infra/utils/snowflake_utils.py index a467a9de421..ab091e75e59 100644 --- a/sdk/python/feast/infra/utils/snowflake_utils.py +++ b/sdk/python/feast/infra/utils/snowflake_utils.py @@ -59,10 +59,6 @@ def get_snowflake_conn(config, autocommit=True) -> SnowflakeConnection: kwargs.update((k, v) for k, v in config_dict.items() if v is not None) - for k, v in kwargs.items(): - if k in ["role", "warehouse", "database", "schema_"]: - kwargs[k] = f'"{v}"' - if "schema_" in kwargs: kwargs["schema"] = kwargs.pop("schema_") else: