Add query_id to adapter payload and tests.

CHANGELOG.md

@@ -6,6 +6,13 @@
 ### Fixes
 - Add unique\_id field to docs generation test catalogs; a follow-on PR to core PR ([#4168](https://github.com/dbt-labs/dbt-core/pull/4618))
 
+### Under the hood
+- Add `query_id` for a query to `run_result.json` ([#40](https://github.com/dbt-labs/dbt-snowflake/pull/40))
+
+### Contributors
+- [@joshuataylor](https://github.com/joshuataylor) ([#40](https://github.com/dbt-labs/dbt-snowflake/pull/40))
+- [@devoted](https://github.com/devoted) ([#40](https://github.com/dbt-labs/dbt-snowflake/pull/40))
+
 ## dbt-snowflake 1.0.0 (December 3rd, 2021)
 
 ## dbt-snowflake 1.0.0rc2 (November 24, 2021)

dbt/adapters/snowflake/connections.py

@@ -28,6 +28,11 @@
 _TOKEN_REQUEST_URL = 'https://{}.snowflakecomputing.com/oauth/token-request'
 
 
+@dataclass
+class SnowflakeAdapterResponse(AdapterResponse):
+    query_id: str = ""
+
+
 @dataclass
 class SnowflakeCredentials(Credentials):
     account: str
@@ -346,16 +351,17 @@ def cancel(self, connection):
         logger.debug("Cancel query '{}': {}".format(connection_name, res))
 
     @classmethod
-    def get_response(cls, cursor) -> AdapterResponse:
+    def get_response(cls, cursor) -> SnowflakeAdapterResponse:
         code = cursor.sqlstate
 
         if code is None:
             code = 'SUCCESS'
 
-        return AdapterResponse(
+        return SnowflakeAdapterResponse(
             _message="{} {}".format(code, cursor.rowcount),
             rows_affected=cursor.rowcount,
-            code=code
+            code=code,
+            query_id=cursor.sfqid
         )
 
     # disable transactional logic by default on Snowflake

tests/integration/adapter_methods_test/test_adapter_methods.py

@@ -19,6 +19,12 @@ def project_config(self):
 
     @use_profile('snowflake')
     def test_snowflake_adapter_methods(self):
-        self.run_dbt(['compile'])  # trigger any compile-time issues
+        self.run_dbt(['compile'])
         self.run_dbt()
         self.assertTablesEqual('MODEL', 'EXPECTED')
+
+    @use_profile('snowflake')
+    def test_snowflake_adapter_query_id(self):
+        results = self.run_dbt()
+        # strip to ensure nonempty string doesn't get passed
+        assert results[0].adapter_response['query_id'].strip() != ""