fix: update snowflake debug info to use direct SQL commands

Co-Authored-By: Aaron <AJ> Steers <aj@airbyte.io>

Author: devin-ai-integration[bot]

.github/workflows/python_pytest.yml

@@ -164,11 +164,13 @@ jobs:
     # Job-specific step(s):
     - name: Print Snowflake Test Environment Info
       if: ${{ !github.event.pull_request.head.repo.fork }}
+      env:
+        GCP_GSM_CREDENTIALS: ${{ secrets.GCP_GSM_CREDENTIALS }}
       run: |
         echo "=== Snowflake Test Environment ==="
-        echo "Snowflake Account Info (non-sensitive):"
+        echo "Running Snowflake commands to get environment info..."
         poetry run python -c "
-import airbyte as ab
+from airbyte._processors.sql.snowflake import SnowflakeConfig, SnowflakeSqlProcessor
 from airbyte.secrets import GoogleGSMSecretManager
 
 try:
@@ -177,11 +179,11 @@ try:
         credentials_json=ab.get_secret('GCP_GSM_CREDENTIALS')
     )
     config = gsm.get_secret('AIRBYTE_LIB_SNOWFLAKE_CREDS').parse_json()
-    print(f'Account: {config.get(\"account\", \"<not-set>\")}')
-    print(f'Username: {config.get(\"username\", \"<not-set>\")}')
-    print(f'Default DB: {config.get(\"database\", \"<not-set>\")}')
+    snowflake_config = SnowflakeConfig(**config)
+    processor = SnowflakeSqlProcessor(snowflake_config)
+    processor._init_connection_settings(processor.connection)
 except Exception as e:
-    print(f'Error getting Snowflake config: {str(e)}')"
+    print(f'Error getting Snowflake info: {str(e)}')"
 
     - name: Run Pytest
       timeout-minutes: 60

airbyte/_processors/sql/snowflake.py

@@ -232,7 +232,10 @@ def _init_connection_settings(self, connection: Connection) -> None:
                 SELECT
                     CURRENT_USER() as USERNAME,
                     CURRENT_ACCOUNT() as ACCOUNT_NAME,
-                    CURRENT_DATABASE() as DATABASE_NAME;
+                    CURRENT_DATABASE() as DATABASE_NAME,
+                    CURRENT_SCHEMA() as SCHEMA_NAME,
+                    CURRENT_WAREHOUSE() as WAREHOUSE_NAME,
+                    CURRENT_ROLE() as ROLE_NAME;
                 """
             )
         )