diff --git a/target_bigquery/batch_job.py b/target_bigquery/batch_job.py index 67f5305..bfa3f5c 100644 --- a/target_bigquery/batch_job.py +++ b/target_bigquery/batch_job.py @@ -63,6 +63,7 @@ def run(self) -> None: BytesIO(job.data), job.table, num_retries=3, + timeout=self.config.get("timeout", 600), job_config=bigquery.LoadJobConfig(**job.config), ).result() except Exception as exc: