@@ -176,7 +176,7 @@ public Dataset getDatasetSkipExceptionTranslation(
176176
177177 Dataset dataset = bqGetRequest .execute ();
178178 if (getDataset != null ) {
179- getDataset .setAttribute ("bq.rpc.response.id" , dataset .getId ());
179+ getDataset .setAttribute ("bq.rpc.response.dataset. id" , dataset .getId ());
180180 getDataset .end ();
181181 }
182182 return dataset ;
@@ -273,7 +273,7 @@ public Dataset createSkipExceptionTranslation(Dataset dataset, Map<Option, ?> op
273273 }
274274 Dataset datasetResponse = bqCreateRequest .execute ();
275275 if (createDataset != null ) {
276- createDataset .setAttribute ("bq.rpc.response.id" , datasetResponse .getId ());
276+ createDataset .setAttribute ("bq.rpc.response.dataset. id" , datasetResponse .getId ());
277277 createDataset .end ();
278278 }
279279 return datasetResponse ;
@@ -318,7 +318,7 @@ public Table createSkipExceptionTranslation(Table table, Map<Option, ?> options)
318318 }
319319 Table tableResponse = bqCreateRequest .execute ();
320320 if (createTable != null ) {
321- createTable .setAttribute ("bq.rpc.response.id" , tableResponse .getId ());
321+ createTable .setAttribute ("bq.rpc.response.table. id" , tableResponse .getId ());
322322 createTable .end ();
323323 }
324324 return tableResponse ;
@@ -407,8 +407,9 @@ public Job createSkipExceptionTranslation(Job job, Map<Option, ?> options) throw
407407 }
408408 Job jobResponse = bqCreateRequest .execute ();
409409 if (createJob != null ) {
410- createJob .setAttribute ("bq.rpc.response.id" , jobResponse .getId ());
411- createJob .setAttribute ("bq.rpc.response.job.status" , jobResponse .getStatus ().getState ());
410+ createJob .setAttribute ("bq.rpc.response.job.id" , jobResponse .getId ());
411+ createJob .setAttribute (
412+ "bq.rpc.response.job.status.state" , jobResponse .getStatus ().getState ());
412413 createJob .end ();
413414 }
414415 return jobResponse ;
@@ -448,8 +449,9 @@ public Job createJobForQuerySkipExceptionTranslation(Job job) throws IOException
448449 }
449450 Job jobResponse = bqCreateRequest .execute ();
450451 if (createJob != null ) {
451- createJob .setAttribute ("bq.rpc.response.id" , jobResponse .getId ());
452- createJob .setAttribute ("bq.rpc.response.job.status" , jobResponse .getStatus ().getState ());
452+ createJob .setAttribute ("bq.rpc.response.job.id" , jobResponse .getId ());
453+ createJob .setAttribute (
454+ "bq.rpc.response.job.status.state" , jobResponse .getStatus ().getState ());
453455 createJob .end ();
454456 }
455457 return jobResponse ;
@@ -543,7 +545,7 @@ public Dataset patchSkipExceptionTranslation(Dataset dataset, Map<Option, ?> opt
543545 }
544546 Dataset datasetResponse = bqPatchRequest .execute ();
545547 if (patchDataset != null ) {
546- patchDataset .setAttribute ("bq.rpc.response.id" , datasetResponse .getId ());
548+ patchDataset .setAttribute ("bq.rpc.response.dataset. id" , datasetResponse .getId ());
547549 patchDataset .end ();
548550 }
549551 return datasetResponse ;
@@ -590,7 +592,7 @@ public Table patchSkipExceptionTranslation(Table table, Map<Option, ?> options)
590592 }
591593 Table tableResponse = bqPatchRequest .execute ();
592594 if (patchTable != null ) {
593- patchTable .setAttribute ("bq.rpc.response.id" , tableResponse .getId ());
595+ patchTable .setAttribute ("bq.rpc.response.table. id" , tableResponse .getId ());
594596 patchTable .end ();
595597 }
596598 return tableResponse ;
@@ -639,7 +641,7 @@ public Table getTableSkipExceptionTranslation(
639641 }
640642 Table tableResponse = bqGetRequest .execute ();
641643 if (getTable != null ) {
642- getTable .setAttribute ("bq.rpc.response.id" , tableResponse .getId ());
644+ getTable .setAttribute ("bq.rpc.response.table. id" , tableResponse .getId ());
643645 getTable .end ();
644646 }
645647 return tableResponse ;
@@ -1311,8 +1313,8 @@ public Job getJobSkipExceptionTranslation(
13111313 }
13121314 Job jobResponse = bqGetRequest .execute ();
13131315 if (getJob != null ) {
1314- getJob .setAttribute ("bq.rpc.response.id" , jobResponse .getId ());
1315- getJob .setAttribute ("bq.rpc.response.job.status" , jobResponse .getStatus ().getState ());
1316+ getJob .setAttribute ("bq.rpc.response.job. id" , jobResponse .getId ());
1317+ getJob .setAttribute ("bq.rpc.response.job.status.state " , jobResponse .getStatus ().getState ());
13161318 getJob .end ();
13171319 }
13181320 return jobResponse ;
@@ -1353,8 +1355,8 @@ public Job getQueryJobSkipExceptionTranslation(String projectId, String jobId, S
13531355 }
13541356 Job jobResponse = bqGetRequest .execute ();
13551357 if (getJob != null ) {
1356- getJob .setAttribute ("bq.rpc.response.id" , jobResponse .getId ());
1357- getJob .setAttribute ("bq.rpc.response.job.status" , jobResponse .getStatus ().getState ());
1358+ getJob .setAttribute ("bq.rpc.response.job. id" , jobResponse .getId ());
1359+ getJob .setAttribute ("bq.rpc.response.job.status.state " , jobResponse .getStatus ().getState ());
13581360 getJob .end ();
13591361 }
13601362 return jobResponse ;
0 commit comments