chore: new owl bot post processor docker image (#160)

gcr.io/repo-automation-bots/owlbot-nodejs:latest@sha256:f93bb861d6f12574437bb9aee426b71eafd63b419669ff0ed029f4b7e7162e3f
googleapis · May 10, 2021 · 4d36a11 · 4d36a11
1 parent 909bbe9
commit 4d36a11
Show file tree

Hide file tree

Showing 6 changed files with 84 additions and 99 deletions.
diff --git a/packages/google-cloud-bigquery-storage/protos/protos.d.ts b/packages/google-cloud-bigquery-storage/protos/protos.d.ts
diff --git a/packages/google-cloud-bigquery-storage/protos/protos.js b/packages/google-cloud-bigquery-storage/protos/protos.js
diff --git a/packages/google-cloud-bigquery-storage/src/v1/big_query_read_client.ts b/packages/google-cloud-bigquery-storage/src/v1/big_query_read_client.ts
@@ -230,13 +230,14 @@ export class BigQueryReadClient {
  ];
  for (const methodName of bigQueryReadStubMethods) {
  const callPromise = this.bigQueryReadStub.then(
- stub => (...args: Array<{}>) => {
- if (this._terminated) {
- return Promise.reject('The client has already been closed.');
- }
- const func = stub[methodName];
- return func.apply(stub, args);
- },
+ stub =>
+ (...args: Array<{}>) => {
+ if (this._terminated) {
+ return Promise.reject('The client has already been closed.');
+ }
+ const func = stub[methodName];
+ return func.apply(stub, args);
+ },
  (err: Error | null | undefined) => () => {
  throw err;
  }
@@ -432,11 +433,10 @@ export class BigQueryReadClient {
  options = options || {};
  options.otherArgs = options.otherArgs || {};
  options.otherArgs.headers = options.otherArgs.headers || {};
- options.otherArgs.headers[
- 'x-goog-request-params'
- ] = gax.routingHeader.fromParams({
- 'read_session.table': request.readSession!.table || '',
- });
+ options.otherArgs.headers['x-goog-request-params'] =
+ gax.routingHeader.fromParams({
+ 'read_session.table': request.readSession!.table || '',
+ });
  this.initialize();
  return this.innerApiCalls.createReadSession(request, options, callback);
  }
@@ -549,11 +549,10 @@ export class BigQueryReadClient {
  options = options || {};
  options.otherArgs = options.otherArgs || {};
  options.otherArgs.headers = options.otherArgs.headers || {};
- options.otherArgs.headers[
- 'x-goog-request-params'
- ] = gax.routingHeader.fromParams({
- name: request.name || '',
- });
+ options.otherArgs.headers['x-goog-request-params'] =
+ gax.routingHeader.fromParams({
+ name: request.name || '',
+ });
  this.initialize();
  return this.innerApiCalls.splitReadStream(request, options, callback);
  }
@@ -595,11 +594,10 @@ export class BigQueryReadClient {
  options = options || {};
  options.otherArgs = options.otherArgs || {};
  options.otherArgs.headers = options.otherArgs.headers || {};
- options.otherArgs.headers[
- 'x-goog-request-params'
- ] = gax.routingHeader.fromParams({
- read_stream: request.readStream || '',
- });
+ options.otherArgs.headers['x-goog-request-params'] =
+ gax.routingHeader.fromParams({
+ read_stream: request.readStream || '',
+ });
  this.initialize();
  return this.innerApiCalls.readRows(request, options);
  }

diff --git a/packages/google-cloud-bigquery-storage/src/v1beta1/big_query_storage_client.ts b/packages/google-cloud-bigquery-storage/src/v1beta1/big_query_storage_client.ts
@@ -233,13 +233,14 @@ export class BigQueryStorageClient {
  ];
  for (const methodName of bigQueryStorageStubMethods) {
  const callPromise = this.bigQueryStorageStub.then(
- stub => (...args: Array<{}>) => {
- if (this._terminated) {
- return Promise.reject('The client has already been closed.');
- }
- const func = stub[methodName];
- return func.apply(stub, args);
- },
+ stub =>
+ (...args: Array<{}>) => {
+ if (this._terminated) {
+ return Promise.reject('The client has already been closed.');
+ }
+ const func = stub[methodName];
+ return func.apply(stub, args);
+ },
  (err: Error | null | undefined) => () => {
  throw err;
  }
@@ -437,12 +438,11 @@ export class BigQueryStorageClient {
  options = options || {};
  options.otherArgs = options.otherArgs || {};
  options.otherArgs.headers = options.otherArgs.headers || {};
- options.otherArgs.headers[
- 'x-goog-request-params'
- ] = gax.routingHeader.fromParams({
- 'table_reference.project_id': request.tableReference!.projectId || '',
- 'table_reference.dataset_id': request.tableReference!.datasetId || '',
- });
+ options.otherArgs.headers['x-goog-request-params'] =
+ gax.routingHeader.fromParams({
+ 'table_reference.project_id': request.tableReference!.projectId || '',
+ 'table_reference.dataset_id': request.tableReference!.datasetId || '',
+ });
  this.initialize();
  return this.innerApiCalls.createReadSession(request, options, callback);
  }
@@ -543,11 +543,10 @@ export class BigQueryStorageClient {
  options = options || {};
  options.otherArgs = options.otherArgs || {};
  options.otherArgs.headers = options.otherArgs.headers || {};
- options.otherArgs.headers[
- 'x-goog-request-params'
- ] = gax.routingHeader.fromParams({
- 'session.name': request.session!.name || '',
- });
+ options.otherArgs.headers['x-goog-request-params'] =
+ gax.routingHeader.fromParams({
+ 'session.name': request.session!.name || '',
+ });
  this.initialize();
  return this.innerApiCalls.batchCreateReadSessionStreams(
  request,
@@ -658,11 +657,10 @@ export class BigQueryStorageClient {
  options = options || {};
  options.otherArgs = options.otherArgs || {};
  options.otherArgs.headers = options.otherArgs.headers || {};
- options.otherArgs.headers[
- 'x-goog-request-params'
- ] = gax.routingHeader.fromParams({
- 'stream.name': request.stream!.name || '',
- });
+ options.otherArgs.headers['x-goog-request-params'] =
+ gax.routingHeader.fromParams({
+ 'stream.name': request.stream!.name || '',
+ });
  this.initialize();
  return this.innerApiCalls.finalizeStream(request, options, callback);
  }
@@ -776,11 +774,10 @@ export class BigQueryStorageClient {
  options = options || {};
  options.otherArgs = options.otherArgs || {};
  options.otherArgs.headers = options.otherArgs.headers || {};
- options.otherArgs.headers[
- 'x-goog-request-params'
- ] = gax.routingHeader.fromParams({
- 'original_stream.name': request.originalStream!.name || '',
- });
+ options.otherArgs.headers['x-goog-request-params'] =
+ gax.routingHeader.fromParams({
+ 'original_stream.name': request.originalStream!.name || '',
+ });
  this.initialize();
  return this.innerApiCalls.splitReadStream(request, options, callback);
  }
@@ -822,11 +819,10 @@ export class BigQueryStorageClient {
  options = options || {};
  options.otherArgs = options.otherArgs || {};
  options.otherArgs.headers = options.otherArgs.headers || {};
- options.otherArgs.headers[
- 'x-goog-request-params'
- ] = gax.routingHeader.fromParams({
- 'read_position.stream.name': request.readPosition!.stream!.name || '',
- });
+ options.otherArgs.headers['x-goog-request-params'] =
+ gax.routingHeader.fromParams({
+ 'read_position.stream.name': request.readPosition!.stream!.name || '',
+ });
  this.initialize();
  return this.innerApiCalls.readRows(request, options);
  }

diff --git a/packages/google-cloud-bigquery-storage/test/gapic_big_query_read_v1.ts b/packages/google-cloud-bigquery-storage/test/gapic_big_query_read_v1.ts
@@ -28,10 +28,9 @@ import {PassThrough} from 'stream';
 import {protobuf} from 'google-gax';
 
 function generateSampleMessage<T extends object>(instance: T) {
- const filledObject = (instance.constructor as typeof protobuf.Message).toObject(
- instance as protobuf.Message<T>,
- {defaults: true}
- );
+ const filledObject = (
+ instance.constructor as typeof protobuf.Message
+ ).toObject(instance as protobuf.Message<T>, {defaults: true});
  return (instance.constructor as typeof protobuf.Message).fromObject(
  filledObject
  ) as T;
@@ -209,9 +208,8 @@ describe('v1.BigQueryReadClient', () => {
  const expectedResponse = generateSampleMessage(
  new protos.google.cloud.bigquery.storage.v1.ReadSession()
  );
- client.innerApiCalls.createReadSession = stubSimpleCallWithCallback(
- expectedResponse
- );
+ client.innerApiCalls.createReadSession =
+ stubSimpleCallWithCallback(expectedResponse);
  const promise = new Promise((resolve, reject) => {
  client.createReadSession(
  request,
@@ -322,9 +320,8 @@ describe('v1.BigQueryReadClient', () => {
  const expectedResponse = generateSampleMessage(
  new protos.google.cloud.bigquery.storage.v1.SplitReadStreamResponse()
  );
- client.innerApiCalls.splitReadStream = stubSimpleCallWithCallback(
- expectedResponse
- );
+ client.innerApiCalls.splitReadStream =
+ stubSimpleCallWithCallback(expectedResponse);
  const promise = new Promise((resolve, reject) => {
  client.splitReadStream(
  request,

diff --git a/packages/google-cloud-bigquery-storage/test/gapic_big_query_storage_v1beta1.ts b/packages/google-cloud-bigquery-storage/test/gapic_big_query_storage_v1beta1.ts
@@ -28,10 +28,9 @@ import {PassThrough} from 'stream';
 import {protobuf} from 'google-gax';
 
 function generateSampleMessage<T extends object>(instance: T) {
- const filledObject = (instance.constructor as typeof protobuf.Message).toObject(
- instance as protobuf.Message<T>,
- {defaults: true}
- );
+ const filledObject = (
+ instance.constructor as typeof protobuf.Message
+ ).toObject(instance as protobuf.Message<T>, {defaults: true});
  return (instance.constructor as typeof protobuf.Message).fromObject(
  filledObject
  ) as T;
@@ -217,9 +216,8 @@ describe('v1beta1.BigQueryStorageClient', () => {
  const expectedResponse = generateSampleMessage(
  new protos.google.cloud.bigquery.storage.v1beta1.ReadSession()
  );
- client.innerApiCalls.createReadSession = stubSimpleCallWithCallback(
- expectedResponse
- );
+ client.innerApiCalls.createReadSession =
+ stubSimpleCallWithCallback(expectedResponse);
  const promise = new Promise((resolve, reject) => {
  client.createReadSession(
  request,
@@ -303,9 +301,8 @@ describe('v1beta1.BigQueryStorageClient', () => {
  const expectedResponse = generateSampleMessage(
  new protos.google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsResponse()
  );
- client.innerApiCalls.batchCreateReadSessionStreams = stubSimpleCall(
- expectedResponse
- );
+ client.innerApiCalls.batchCreateReadSessionStreams =
+ stubSimpleCall(expectedResponse);
  const [response] = await client.batchCreateReadSessionStreams(request);
  assert.deepStrictEqual(response, expectedResponse);
  assert(
@@ -337,9 +334,8 @@ describe('v1beta1.BigQueryStorageClient', () => {
  const expectedResponse = generateSampleMessage(
  new protos.google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsResponse()
  );
- client.innerApiCalls.batchCreateReadSessionStreams = stubSimpleCallWithCallback(
- expectedResponse
- );
+ client.innerApiCalls.batchCreateReadSessionStreams =
+ stubSimpleCallWithCallback(expectedResponse);
  const promise = new Promise((resolve, reject) => {
  client.batchCreateReadSessionStreams(
  request,
@@ -455,9 +451,8 @@ describe('v1beta1.BigQueryStorageClient', () => {
  const expectedResponse = generateSampleMessage(
  new protos.google.protobuf.Empty()
  );
- client.innerApiCalls.finalizeStream = stubSimpleCallWithCallback(
- expectedResponse
- );
+ client.innerApiCalls.finalizeStream =
+ stubSimpleCallWithCallback(expectedResponse);
  const promise = new Promise((resolve, reject) => {
  client.finalizeStream(
  request,
@@ -570,9 +565,8 @@ describe('v1beta1.BigQueryStorageClient', () => {
  const expectedResponse = generateSampleMessage(
  new protos.google.cloud.bigquery.storage.v1beta1.SplitReadStreamResponse()
  );
- client.innerApiCalls.splitReadStream = stubSimpleCallWithCallback(
- expectedResponse
- );
+ client.innerApiCalls.splitReadStream =
+ stubSimpleCallWithCallback(expectedResponse);
  const promise = new Promise((resolve, reject) => {
  client.splitReadStream(
  request,