Skip to content

Commit

Permalink
Merge pull request #8 from seanglynn-thrive/update_deps
Browse files Browse the repository at this point in the history
Update deps
  • Loading branch information
seanglynn-thrive authored Sep 20, 2022
2 parents 08d7a09 + 8be5421 commit 35c8323
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
6 changes: 3 additions & 3 deletions setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
long_description = f.read()

setup(name="pipelinewise-target-bigquery",
version="1.3.1",
version="1.5.1",
description="Singer.io target for loading data to BigQuery - PipelineWise compatible",
long_description=long_description,
long_description_content_type='text/markdown',
Expand All @@ -19,8 +19,8 @@
py_modules=["target_bigquery"],
install_requires=[
'pipelinewise-singer-python>=1,<3',
'google-cloud-bigquery>=2.20.0,<2.35.0',
'fastavro>=0.22.8,<=1.4.9'
'google-cloud-bigquery>=2.20.0,<=3.3.2',
'fastavro>=0.22.8,<=1.6.1'
],
extras_require={
"test": [
Expand Down
4 changes: 2 additions & 2 deletions run_bq_retry.py → tests/run_bq_retry.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,9 @@
logging.getLogger().setLevel(logging.DEBUG)


## 1. Retry at the Google API level (Deadline = 30 seconds)
## 1. Retry at the Google API level (Deadline = 120 seconds)
# NOTE: We can isolate the exception types at a later point - Just use `Exception` for now
@Retry(predicate=if_exception_type(Exception), deadline=30)
@Retry(predicate=if_exception_type(Exception), deadline=120)
def query(client, query, params=[]) -> bigquery.job.query.QueryJob:
def to_query_parameter(value):
if isinstance(value, int):
Expand Down

0 comments on commit 35c8323

Please sign in to comment.