Update bigquery_tools.py (apache#31444)

fix apache#31414
m-trieu · May 29, 2024 · 90f0209 · 90f0209
1 parent 80d85aa
commit 90f0209
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/python/apache_beam/io/gcp/bigquery_tools.py b/sdks/python/apache_beam/io/gcp/bigquery_tools.py
@@ -649,7 +649,7 @@ def wait_for_bq_job(self, job_reference, sleep_duration_sec=5, max_retries=0):
       retry += 1
       job = self.get_job(
           job_reference.projectId, job_reference.jobId, job_reference.location)
-      logging.info('Job %s status: %s', job.id, job.status.state)
+      _LOGGER.info('Job %s status: %s', job.id, job.status.state)
       if job.status.state == 'DONE' and job.status.errorResult:
         raise RuntimeError(
             'BigQuery job {} failed. Error Result: {}'.format(