diff --git a/dbt/adapters/bigquery/python_submissions.py b/dbt/adapters/bigquery/python_submissions.py index 74c090077..bf91f8eab 100644 --- a/dbt/adapters/bigquery/python_submissions.py +++ b/dbt/adapters/bigquery/python_submissions.py @@ -133,7 +133,7 @@ def _submit_dataproc_job(self) -> dataproc_v1.types.jobs.Job: request = dataproc_v1.GetBatchRequest(name = ''.join([parent, "/batches/", batch_id])), # retry=self.retry (This retry polls way too many times per second) ) - state = str(get_batch_response.state) + state = str(response.state) time.sleep(2) return response