wait for job result before emitting complete.

googleapis · Apr 2, 2018 · 1b06d7c · 1b06d7c
1 parent f2f7fce
commit 1b06d7c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/table.js b/src/table.js
@@ -1186,7 +1186,9 @@ Table.prototype.createWriteStream = function(metadata) {
         var job = self.bigQuery.job(data.jobReference.jobId);
         job.metadata = data;
 
-        dup.emit('complete', job);
+        job
+          .on('error', err => dup.destroy(err))
+          .on('complete', () => dup.emit('complete', job));
       }
     );
   });