Abacn commented on PR #32967:
URL: https://github.com/apache/beam/pull/32967#issuecomment-2445071367

   Tested via invoking two perform_load_job sequentially (se the second 
invocation results in 409), then invoking  ` 
bq_wrapper.wait_for_bq_job(response1)`
   
   before:
   
   ```
   response1:  <JobReference
    jobId: 'bqjob_r18373583a1f5a918_00000192d90b0ea8_5'
    projectId: 'google.com:clouddfe'>
   INFO:apache_beam.io.gcp.bigquery_tools:Job 
google.com:clouddfe:EU.bqjob_r18373583a1f5a918_00000192d90b0ea8_5 status: 
RUNNING
   INFO:apache_beam.io.gcp.bigquery_tools:Job 
google.com:clouddfe:EU.bqjob_r18373583a1f5a918_00000192d90b0ea8_5 status: DONE
   ```
   
   after:
   
   ```
   response1:  <JobReference
    jobId: 'bqjob_r18373583a1f5a918_00000192d90b0ea8_6'
    location: 'EU'
    projectId: 'google.com:clouddfe'>
   INFO:apache_beam.io.gcp.bigquery_tools:Job 
google.com:clouddfe:EU.bqjob_r18373583a1f5a918_00000192d90b0ea8_6 status: 
RUNNING
   INFO:apache_beam.io.gcp.bigquery_tools:Job 
google.com:clouddfe:EU.bqjob_r18373583a1f5a918_00000192d90b0ea8_6 status: DONE
   ```
   
   as can be seen, perform_load_job now returns a JobReference with location 
field, and wait_for_bq_job still finishes successfully


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to