Skip to content

Commit

Permalink
Increase timeout value from 30->120 seconds
Browse files Browse the repository at this point in the history
  • Loading branch information
seanglynn-thrive committed Sep 20, 2022
1 parent 2e30cce commit a1d3cb0
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions target_bigquery/db_sync.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand Down

0 comments on commit a1d3cb0

Please sign in to comment.