@@ -52,19 +52,29 @@ def remove_resources(single: str, plural: str, known_instances: t.List[str], rol
52
52
remove_resource (resource_type = single , item = item , role = role )
53
53
54
54
55
+ def _get_private_key_data () -> t .Dict [str , str | None ]:
56
+ if private_key_raw := os .getenv (
57
+ "SNOWFLAKE_CONNECTIONS_INTEGRATION_PRIVATE_KEY_RAW"
58
+ ):
59
+ return {"private_key_raw" : private_key_raw }
60
+ return {
61
+ "private_key_file" : os .getenv (
62
+ "SNOWFLAKE_CONNECTIONS_INTEGRATION_PRIVATE_KEY_FILE"
63
+ )
64
+ }
65
+
66
+
55
67
if __name__ == "__main__" :
56
68
role = os .getenv ("SNOWFLAKE_CONNECTIONS_INTEGRATION_ROLE" , "INTEGRATION_TESTS" )
57
69
config = {
58
70
"authenticator" : "SNOWFLAKE_JWT" ,
59
71
"host" : os .getenv ("SNOWFLAKE_CONNECTIONS_INTEGRATION_HOST" ),
60
72
"account" : os .getenv ("SNOWFLAKE_CONNECTIONS_INTEGRATION_ACCOUNT" ),
61
73
"user" : os .getenv ("SNOWFLAKE_CONNECTIONS_INTEGRATION_USER" ),
62
- "private_key_raw" : os .getenv (
63
- "SNOWFLAKE_CONNECTIONS_INTEGRATION_PRIVATE_KEY_RAW"
64
- ),
65
74
"database" : "SNOWCLI_DB" ,
66
75
"schema" : "public" ,
67
76
"role" : role ,
77
+ ** _get_private_key_data (),
68
78
}
69
79
config = {k : v for k , v in config .items () if v is not None }
70
80
update_connection_details_with_private_key (config )
0 commit comments