From a1d3cb05bf3a06c00ac25f65d202c410a2267f5c Mon Sep 17 00:00:00 2001 From: "sean.glynn" Date: Tue, 20 Sep 2022 16:07:17 +0100 Subject: [PATCH] Increase timeout value from 30->120 seconds --- target_bigquery/db_sync.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/target_bigquery/db_sync.py b/target_bigquery/db_sync.py index fb15362..aada141 100644 --- a/target_bigquery/db_sync.py +++ b/target_bigquery/db_sync.py @@ -359,8 +359,8 @@ def __init__(self, connection_config, stream_schema_message=None): self.flatten_schema = flatten_schema(stream_schema_message['schema'], max_level=self.data_flattening_max_level) self.renamed_columns = {} - # 1. Retry at the Google API level (Retry deadline = 30 seconds) - @Retry(predicate=if_exception_type(Exception), deadline=30) + # 1. Retry at the Google API level (Retry deadline = 120 seconds) + @Retry(predicate=if_exception_type(Exception), deadline=120) def query(self, query, params=[]) -> bigquery.job.query.QueryJob: def to_query_parameter(value): if isinstance(value, int):