Merge branch 'main' into yvonne/timestamp-expressions

Author: yvonnep165

.release-please-manifest.json

@@ -65,7 +65,7 @@
   "packages/google-cloud-binaryauthorization": "4.4.0",
   "packages/google-cloud-capacityplanner": "0.1.2",
   "packages/google-cloud-certificatemanager": "2.1.1",
-  "packages/google-cloud-ces": "0.2.0",
+  "packages/google-cloud-ces": "0.3.0",
   "packages/google-cloud-channel": "4.1.2",
   "packages/google-cloud-chronicle": "0.2.1",
   "packages/google-cloud-cloudcontrolspartner": "0.6.1",
@@ -93,7 +93,7 @@
   "packages/google-cloud-devicestreaming": "0.2.1",
   "packages/google-cloud-dialogflow": "7.5.0",
   "packages/google-cloud-dialogflow-cx": "5.7.0",
-  "packages/google-cloud-discoveryengine": "2.5.3",
+  "packages/google-cloud-discoveryengine": "2.6.0",
   "packages/google-cloud-dns": "5.3.1",
   "packages/google-cloud-documentai": "9.6.0",
   "packages/google-cloud-domains": "4.2.1",
@@ -234,10 +234,11 @@
   "packages/google-shopping-merchant-quota": "0.9.0",
   "packages/google-shopping-merchant-reports": "0.14.0",
   "packages/google-shopping-merchant-reviews": "0.6.0",
-  "packages/google-storage-control": "0.8.1",
+  "packages/google-storage-control": "0.8.2",
   "packages/google-storagetransfer": "4.2.1",
   "packages/google-streetview-publish": "0.4.1",
   "packages/grafeas": "6.1.1",
   "packages/typeless-sample-bot": "3.1.1",
-  "packages/google-maps-navconnect": "0.1.0"
+  "packages/google-maps-navconnect": "0.1.0",
+  "packages/google-cloud-datacatalog-lineage-configmanagement": "0.1.0"
 }

changelog.json

@@ -1,6 +1,75 @@
 {
   "repository": "googleapis/google-cloud-node",
   "entries": [
+    {
+      "changes": [
+        {
+          "type": "feat",
+          "sha": "91666d001bdc0d020742784bebc2c4e4bba81de4",
+          "message": "Add initial files for google.cloud.datacatalog.lineage.configmanagement.v1",
+          "issues": [
+            "7842"
+          ]
+        }
+      ],
+      "version": "0.1.0",
+      "language": "JAVASCRIPT",
+      "artifactName": "@google-cloud/configmanagement",
+      "id": "b4bac2c8-ed00-4012-8556-f07e615aebb6",
+      "createTime": "2026-03-25T19:27:43.346Z"
+    },
+    {
+      "changes": [
+        {
+          "type": "feat",
+          "sha": "0e802546d86a64e5317fda86f99ed9f1b1026e0f",
+          "message": "[ces] update public libraries for CES v1",
+          "issues": [
+            "7845"
+          ]
+        }
+      ],
+      "version": "0.3.0",
+      "language": "JAVASCRIPT",
+      "artifactName": "@google-cloud/ces",
+      "id": "bd13ecf3-51bc-4d3e-a789-06036d9d9026",
+      "createTime": "2026-03-25T19:27:43.303Z"
+    },
+    {
+      "changes": [
+        {
+          "type": "fix",
+          "sha": "1dd586015cbc85409f4737c995c750bc694c14c3",
+          "message": "Update jsdocs headers in v2 clients to include …",
+          "issues": [
+            "7851"
+          ],
+          "scope": "storage-control"
+        }
+      ],
+      "version": "0.8.2",
+      "language": "JAVASCRIPT",
+      "artifactName": "@google-cloud/storage-control",
+      "id": "7016585d-b347-4953-b381-78f7b0eccbf6",
+      "createTime": "2026-03-25T19:27:43.262Z"
+    },
+    {
+      "changes": [
+        {
+          "type": "feat",
+          "sha": "694358739b082ad17f42800b42e5dbbf4c2c975b",
+          "message": "[discoveryengine] Update DataStoreSpec and add BoostSpec to SearchService",
+          "issues": [
+            "7837"
+          ]
+        }
+      ],
+      "version": "2.6.0",
+      "language": "JAVASCRIPT",
+      "artifactName": "@google-cloud/discoveryengine",
+      "id": "74179f79-1668-445d-9990-91aebf8611b6",
+      "createTime": "2026-03-25T19:27:43.222Z"
+    },
     {
       "changes": [
         {
@@ -69306,5 +69375,5 @@
       "createTime": "2023-01-28T04:18:24.718Z"
     }
   ],
-  "updateTime": "2026-03-19T21:58:31.408Z"
+  "updateTime": "2026-03-25T19:27:43.346Z"
 }

core/packages/gax/package.json

@@ -19,7 +19,7 @@
     "object-hash": "^3.0.0",
     "proto3-json-serializer": "3.0.4",
     "protobufjs": "^7.5.4",
-    "retry-request": "8.0.2",
+    "retry-request": "^8.0.2",
     "rimraf": "^5.0.1"
   },
   "devDependencies": {

core/packages/tools/package.json

@@ -32,7 +32,7 @@
   "dependencies": {
     "@babel/core": "^7.26.8",
     "@babel/traverse": "^7.26.8",
-    "google-gax": "5.0.6",
+    "google-gax": "^5.0.6",
     "google-proto-files": "^5.0.0",
     "protobufjs-cli": "^1.2.0",
     "uglify-js": "^3.19.3",

handwritten/bigquery/src/bigquery.ts

@@ -128,6 +128,7 @@ export type Query = JobRequest<bigquery.IJobConfigurationQuery> & {
   pageToken?: string;
   wrapIntegers?: boolean | IntegerTypeCastOptions;
   parseJSON?: boolean;
+  skipParsing?: boolean;
   // Overrides default job creation mode set on the client.
   jobCreationMode?: JobCreationMode;
 };
@@ -2217,6 +2218,7 @@ export class BigQuery extends Service {
         ? {
             wrapIntegers: query.wrapIntegers,
             parseJSON: query.parseJSON,
+            skipParsing: query.skipParsing,
           }
         : {};
     const callback =
@@ -2268,12 +2270,16 @@ export class BigQuery extends Service {
               'formatOptions.useInt64Timestamp':
                 queryReq.formatOptions?.useInt64Timestamp,
             };
-            rows = BigQuery.mergeSchemaWithRows_(res.schema, res.rows, {
-              wrapIntegers: options.wrapIntegers || false,
-              parseJSON: options.parseJSON,
-              listParams,
-            });
-            delete res.rows;
+            if (options.skipParsing) {
+              rows = res.rows;
+            } else {
+              rows = BigQuery.mergeSchemaWithRows_(res.schema, res.rows, {
+                wrapIntegers: options.wrapIntegers || false,
+                parseJSON: options.parseJSON,
+                listParams,
+              });
+              delete res.rows;
+            }
           } catch (e) {
             (callback as SimpleQueryRowsCallback)(e as Error, null, job);
             return;

handwritten/bigquery/src/job.ts

@@ -51,6 +51,7 @@ export type QueryResultsOptions = {
   job?: Job;
   wrapIntegers?: boolean | IntegerTypeCastOptions;
   parseJSON?: boolean;
+  skipParsing?: boolean;
 } & PagedRequest<bigquery.jobs.IGetQueryResultsParams> & {
     /**
      * internal properties
@@ -602,10 +603,15 @@ class Job extends Operation {
             error never makes it to the callback. Instead, pass the error to the
             callback the user provides so that the user can see the error.
              */
-            rows = BigQuery.mergeSchemaWithRows_(resp.schema, resp.rows, {
-              wrapIntegers,
-              parseJSON,
-            });
+            if (options.skipParsing) {
+              rows = resp.rows;
+            } else {
+              rows = BigQuery.mergeSchemaWithRows_(resp.schema, resp.rows, {
+                wrapIntegers,
+                parseJSON,
+              });
+              delete resp.rows;
+            }
           } catch (e) {
             callback!(e as Error, null, null, resp);
             return;
@@ -633,7 +639,6 @@ class Job extends Operation {
           });
           delete nextQuery.startIndex;
         }
-        delete resp.rows;
         callback!(null, rows, nextQuery, resp);
       },
     );

handwritten/bigquery/src/table.ts

@@ -114,6 +114,7 @@ export type TableRowValue = string | TableRow;
 export type GetRowsOptions = PagedRequest<bigquery.tabledata.IListParams> & {
   wrapIntegers?: boolean | IntegerTypeCastOptions;
   parseJSON?: boolean;
+  skipParsing?: boolean;
 };
 
 export type JobLoadMetadata = JobRequest<bigquery.IJobConfigurationLoad> & {
@@ -1873,12 +1874,20 @@ class Table extends ServiceObject {
         the callback. Instead, pass the error to the callback the user provides
         so that the user can see the error.
          */
-        rows = BigQuery.mergeSchemaWithRows_(this.metadata.schema, rows || [], {
-          wrapIntegers,
-          selectedFields,
-          parseJSON,
-          listParams: qs,
-        });
+        if (options.skipParsing) {
+          rows = rows || [];
+        } else {
+          rows = BigQuery.mergeSchemaWithRows_(
+            this.metadata.schema,
+            rows || [],
+            {
+              wrapIntegers,
+              selectedFields,
+              parseJSON,
+              listParams: qs,
+            },
+          );
+        }
       } catch (err) {
         callback!(err as Error | null, null, null, resp);
         return;

handwritten/bigquery/system-test/bigquery.ts

@@ -354,6 +354,27 @@ describe('BigQuery', () => {
     assert.strictEqual(res.totalRows, '100');
   });
 
+  it('should query with skipParsing', async () => {
+    const [rows] = await bigquery.query({
+      query,
+      skipParsing: true,
+    });
+    assert.strictEqual(rows.length, 100);
+    // Raw rows have an 'f' property containing the fields
+    assert.ok(rows[0].f);
+    assert.strictEqual(typeof rows[0].f[0].v, 'string');
+  });
+
+  it('should query with skipParsing via Dataset.query', async () => {
+    const [rows] = await dataset.query({
+      query,
+      skipParsing: true,
+    });
+    assert.strictEqual(rows.length, 100);
+    assert.ok(rows[0].f);
+    assert.strictEqual(typeof rows[0].f[0].v, 'string');
+  });
+
   it('should query without jobs.query and return all PagedResponse as positional parameters', async () => {
     // force jobs.getQueryResult instead of fast query path
     const jobId = generateName('job');
@@ -575,8 +596,9 @@ describe('BigQuery', () => {
       const QUERY = `SELECT * FROM \`${table.id}\``;
       // eslint-disable-next-line @typescript-eslint/no-var-requires
       const SCHEMA = require('../../system-test/data/schema.json');
-      const TEST_DATA_FILE =
-        require.resolve('../../system-test/data/location-test-data.json');
+      const TEST_DATA_FILE = require.resolve(
+        '../../system-test/data/location-test-data.json',
+      );
 
       before(async () => {
         // create a dataset in a certain location will cascade the location
@@ -879,8 +901,9 @@ describe('BigQuery', () => {
   });
 
   describe('BigQuery/Table', () => {
-    const TEST_DATA_JSON_PATH =
-      require.resolve('../../system-test/data/kitten-test-data.json');
+    const TEST_DATA_JSON_PATH = require.resolve(
+      '../../system-test/data/kitten-test-data.json',
+    );
 
     it('should have created the correct schema', () => {
       assert.deepStrictEqual(table.metadata.schema.fields, SCHEMA);

handwritten/bigquery/test/bigquery.ts

@@ -3243,6 +3243,74 @@ describe('BigQuery', () => {
       });
     });
 
+    it('should delete res.rows if skipParsing is false', done => {
+      const rawRows = [{f: [{v: 'hi'}]}];
+      const resp = {
+        jobComplete: true,
+        schema: {
+          fields: [{name: 'name', type: 'STRING'}],
+        },
+        rows: rawRows,
+      };
+
+      const job = {
+        getQueryResults: (options: {}, callback: Function) => {
+          callback(null, [], null, resp);
+        },
+      };
+
+      bq.runJobsQuery = (reqOpts: {}, callback: Function) => {
+        callback(null, job, resp);
+      };
+
+      bq.query(
+        {
+          query: 'SELECT * FROM table',
+          skipParsing: false,
+        },
+        (err: Error, rows: {}[], nextQuery: {}, response: any) => {
+          assert.ifError(err);
+          // the job Complete callback returned the resp
+          assert.deepStrictEqual(response.rows, undefined);
+          done();
+        },
+      );
+    });
+
+    it('should skip parsing if skipParsing is true', done => {
+      const rawRows = [{f: [{v: 'hi'}]}];
+      const resp = {
+        jobComplete: true,
+        schema: {
+          fields: [{name: 'name', type: 'STRING'}],
+        },
+        rows: rawRows,
+      };
+
+      const job = {
+        getQueryResults: (options: QueryResultsOptions, callback: Function) => {
+          callback(null, options._cachedRows, null, options._cachedResponse);
+        },
+      };
+
+      bq.runJobsQuery = (reqOpts: {}, callback: Function) => {
+        callback(null, job, resp);
+      };
+
+      bq.query(
+        {
+          query: 'SELECT * FROM table',
+          skipParsing: true,
+        },
+        (err: Error, rows: {}[], nextQuery: {}, response: any) => {
+          assert.ifError(err);
+          assert.strictEqual(rows, rawRows);
+          assert.deepStrictEqual(response.rows, rawRows);
+          done();
+        },
+      );
+    });
+
     it('should call job#getQueryResults with query options', done => {
       let queryResultsOpts = {};
       const fakeJob = {

handwritten/bigquery/test/dataset.ts

@@ -1010,6 +1010,20 @@ describe('BigQuery/Dataset', () => {
       ds.query(query);
     });
 
+    it('should pass along skipParsing', done => {
+      const query = {
+        query: 'SELECT * FROM allthedata',
+        skipParsing: true,
+      };
+
+      ds.bigQuery.query = (opts: _root.Query) => {
+        assert.strictEqual(opts.skipParsing, true);
+        done();
+      };
+
+      ds.query(query);
+    });
+
     it('should pass along options', done => {
       // eslint-disable-next-line @typescript-eslint/no-explicit-any
       ds.bigQuery.query = (opts: any) => {