feat: add support for accessing jobs cross-project (#1083)

* feat: add support accessing jobs cross-project * fix test
googleapis · Mar 1, 2022 · 9e5bae2 · 9e5bae2
1 parent 6cbe7da
commit 9e5bae2
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 0 deletions.
diff --git a/src/bigquery.ts b/src/bigquery.ts
@@ -66,6 +66,7 @@ export type JobRequest<J> = J & {
   jobId?: string;
   jobPrefix?: string;
   location?: string;
+  projectId?: string;
 };
 
 export type PagedRequest<P> = P & {

diff --git a/src/job.ts b/src/job.ts
@@ -124,6 +124,7 @@ export type QueryResultsOptions = {
 class Job extends Operation {
   bigQuery: BigQuery;
   location?: string;
+  projectId?: string;
   getQueryResultsStream(
     options?: QueryResultsOptions
   ): ResourceStream<RowMetadata> {
@@ -344,6 +345,10 @@ class Job extends Operation {
       this.location = options.location;
     }
 
+    if (options?.projectId) {
+      this.projectId = options.projectId;
+    }
+
     /**
      * Get the results of a job as a readable object stream.
      *

diff --git a/test/job.ts b/test/job.ts
@@ -147,6 +147,13 @@ describe('BigQuery/Job', () => {
       assert.strictEqual(job.location, options.location);
     });
 
+    it('should accept a projectId option', () => {
+      const options = {projectId: 'cool-project'};
+      const job = new Job(BIGQUERY, JOB_ID, options);
+
+      assert.strictEqual(job.projectId, options.projectId);
+    });
+
     it('should send the location via getMetadata', () => {
       const job = new Job(BIGQUERY, JOB_ID, {location: LOCATION});
       const calledWith = job.calledWith_[0];