diff --git a/sdk/python/feast/infra/utils/snowflake_utils.py b/sdk/python/feast/infra/utils/snowflake_utils.py index 6ba9e544894..6b3500b605e 100644 --- a/sdk/python/feast/infra/utils/snowflake_utils.py +++ b/sdk/python/feast/infra/utils/snowflake_utils.py @@ -88,6 +88,8 @@ def get_snowflake_conn(config, autocommit=True) -> SnowflakeConnection: **kwargs, ) + conn.cursor().execute("ALTER SESSION SET TIMEZONE = 'UTC'", _is_internal=True) + return conn except KeyError as e: raise SnowflakeIncompleteConfig(e)