Skip to content
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: googleapis/python-bigquery-storage
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: v2.20.0
Choose a base ref
...
head repository: googleapis/python-bigquery-storage
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: v2.21.0
Choose a head ref
  • 9 commits
  • 24 files changed
  • 5 contributors

Commits on Jun 1, 2023

  1. chore(deps): update all dependencies (#591)

    Co-authored-by: Anthonios Partheniou <partheniou@google.com>
    renovate-bot and parthea authored Jun 1, 2023

    Verified

    This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
    Copy the full SHA
    4ca1292 View commit details
  2. Verified

    This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
    Copy the full SHA
    a732b87 View commit details

Commits on Jun 3, 2023

  1. build(deps): bump cryptography from 39.0.1 to 41.0.0 in /synthtool/gc…

    …p/templates/python_library/.kokoro (#602)
    
    Source-Link: googleapis/synthtool@d0f51a0
    Post-Processor: gcr.io/cloud-devrel-public-resources/owlbot-python:latest@sha256:240b5bcc2bafd450912d2da2be15e62bc6de2cf839823ae4bf94d4f392b451dc
    
    Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
    gcf-owl-bot[bot] and gcf-owl-bot[bot] authored Jun 3, 2023

    Verified

    This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
    Copy the full SHA
    c59e7f4 View commit details

Commits on Jun 22, 2023

  1. Verified

    This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
    Copy the full SHA
    4884cd2 View commit details
  2. feat: add estimated physical file sizes to ReadAPI v1 (#605)

    * feat: add estimated physical file sizes to ReadAPI v1
    
    PiperOrigin-RevId: 542350532
    
    Source-Link: googleapis/googleapis@a4ff1c2
    
    Source-Link: googleapis/googleapis-gen@b5b5fe5
    Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYjViNWZlNWRjZDRiY2UxNWI3YjkwMzViOTI1NDUyZWU3Y2FmNDg5YiJ9
    
    * 🦉 Updates from OwlBot post-processor
    
    See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md
    
    ---------
    
    Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
    Co-authored-by: Anthonios Partheniou <partheniou@google.com>
    3 people authored Jun 22, 2023

    Verified

    This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
    Copy the full SHA
    ad342fe View commit details

Commits on Jun 27, 2023

  1. chore: remove pinned Sphinx version [autoapprove] (#608)

    Source-Link: googleapis/synthtool@909573c
    Post-Processor: gcr.io/cloud-devrel-public-resources/owlbot-python:latest@sha256:ddf4551385d566771dc713090feb7b4c1164fb8a698fe52bbe7670b24236565b
    
    Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
    gcf-owl-bot[bot] and gcf-owl-bot[bot] authored Jun 27, 2023

    Verified

    This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
    Copy the full SHA
    6148ee5 View commit details

Commits on Jun 29, 2023

  1. chore: store artifacts in placer (#609)

    Source-Link: googleapis/synthtool@cb96037
    Post-Processor: gcr.io/cloud-devrel-public-resources/owlbot-python:latest@sha256:2d816f26f728ac8b24248741e7d4c461c09764ef9f7be3684d557c9632e46dbd
    
    Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
    gcf-owl-bot[bot] and gcf-owl-bot[bot] authored Jun 29, 2023

    Verified

    This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
    Copy the full SHA
    f007eb2 View commit details

Commits on Jul 4, 2023

  1. fix: Add async context manager return types (#610)

    * fix: Add async context manager return types
    
    chore: Mock return_value should not populate oneof message fields
    
    chore: Support snippet generation for services that only support REST transport
    
    chore: Update gapic-generator-python to v1.11.0
    PiperOrigin-RevId: 545430278
    
    Source-Link: googleapis/googleapis@601b532
    
    Source-Link: googleapis/googleapis-gen@b3f18d0
    Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYjNmMThkMGY2NTYwYTg1NTAyMmZkMDU4ODY1ZTc2MjA0NzlkN2FmOSJ9
    
    * fix: Add async context manager return types
    
    chore: Mock return_value should not populate oneof message fields
    
    chore: Support snippet generation for services that only support REST transport
    
    chore: Update gapic-generator-python to v1.11.0
    PiperOrigin-RevId: 545430278
    
    Source-Link: googleapis/googleapis@601b532
    
    Source-Link: googleapis/googleapis-gen@b3f18d0
    Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYjNmMThkMGY2NTYwYTg1NTAyMmZkMDU4ODY1ZTc2MjA0NzlkN2FmOSJ9
    
    * 🦉 Updates from OwlBot post-processor
    
    See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md
    
    * 🦉 Updates from OwlBot post-processor
    
    See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md
    
    ---------
    
    Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
    gcf-owl-bot[bot] and gcf-owl-bot[bot] authored Jul 4, 2023

    Verified

    This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
    Copy the full SHA
    e7069d1 View commit details

Commits on Jul 5, 2023

  1. chore(main): release 2.21.0 (#607)

    Co-authored-by: release-please[bot] <55107282+release-please[bot]@users.noreply.github.com>
    release-please[bot] authored Jul 5, 2023

    Verified

    This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
    Copy the full SHA
    a8d0341 View commit details
4 changes: 2 additions & 2 deletions .github/.OwlBot.lock.yaml
Original file line number Diff line number Diff line change
@@ -13,5 +13,5 @@
# limitations under the License.
docker:
image: gcr.io/cloud-devrel-public-resources/owlbot-python:latest
digest: sha256:9bc5fa3b62b091f60614c08a7fb4fd1d3e1678e326f34dd66ce1eefb5dc3267b
# created: 2023-05-25T14:56:16.294623272Z
digest: sha256:2d816f26f728ac8b24248741e7d4c461c09764ef9f7be3684d557c9632e46dbd
# created: 2023-06-28T17:03:33.371210701Z
9 changes: 9 additions & 0 deletions .kokoro/release/common.cfg
Original file line number Diff line number Diff line change
@@ -38,3 +38,12 @@ env_vars: {
key: "SECRET_MANAGER_KEYS"
value: "releasetool-publish-reporter-app,releasetool-publish-reporter-googleapis-installation,releasetool-publish-reporter-pem"
}

# Store the packages we uploaded to PyPI. That way, we have a record of exactly
# what we published, which we can use to generate SBOMs and attestations.
action {
define_artifacts {
regex: "github/python-bigquery-storage/**/*.tar.gz"
strip_prefix: "github/python-bigquery-storage"
}
}
42 changes: 20 additions & 22 deletions .kokoro/requirements.txt
Original file line number Diff line number Diff line change
@@ -113,28 +113,26 @@ commonmark==0.9.1 \
--hash=sha256:452f9dc859be7f06631ddcb328b6919c67984aca654e5fefb3914d54691aed60 \
--hash=sha256:da2f38c92590f83de410ba1a3cbceafbc74fee9def35f9251ba9a971d6d66fd9
# via rich
cryptography==39.0.1 \
--hash=sha256:0f8da300b5c8af9f98111ffd512910bc792b4c77392a9523624680f7956a99d4 \
--hash=sha256:35f7c7d015d474f4011e859e93e789c87d21f6f4880ebdc29896a60403328f1f \
--hash=sha256:5aa67414fcdfa22cf052e640cb5ddc461924a045cacf325cd164e65312d99502 \
--hash=sha256:5d2d8b87a490bfcd407ed9d49093793d0f75198a35e6eb1a923ce1ee86c62b41 \
--hash=sha256:6687ef6d0a6497e2b58e7c5b852b53f62142cfa7cd1555795758934da363a965 \
--hash=sha256:6f8ba7f0328b79f08bdacc3e4e66fb4d7aab0c3584e0bd41328dce5262e26b2e \
--hash=sha256:706843b48f9a3f9b9911979761c91541e3d90db1ca905fd63fee540a217698bc \
--hash=sha256:807ce09d4434881ca3a7594733669bd834f5b2c6d5c7e36f8c00f691887042ad \
--hash=sha256:83e17b26de248c33f3acffb922748151d71827d6021d98c70e6c1a25ddd78505 \
--hash=sha256:96f1157a7c08b5b189b16b47bc9db2332269d6680a196341bf30046330d15388 \
--hash=sha256:aec5a6c9864be7df2240c382740fcf3b96928c46604eaa7f3091f58b878c0bb6 \
--hash=sha256:b0afd054cd42f3d213bf82c629efb1ee5f22eba35bf0eec88ea9ea7304f511a2 \
--hash=sha256:ced4e447ae29ca194449a3f1ce132ded8fcab06971ef5f618605aacaa612beac \
--hash=sha256:d1f6198ee6d9148405e49887803907fe8962a23e6c6f83ea7d98f1c0de375695 \
--hash=sha256:e124352fd3db36a9d4a21c1aa27fd5d051e621845cb87fb851c08f4f75ce8be6 \
--hash=sha256:e422abdec8b5fa8462aa016786680720d78bdce7a30c652b7fadf83a4ba35336 \
--hash=sha256:ef8b72fa70b348724ff1218267e7f7375b8de4e8194d1636ee60510aae104cd0 \
--hash=sha256:f0c64d1bd842ca2633e74a1a28033d139368ad959872533b1bab8c80e8240a0c \
--hash=sha256:f24077a3b5298a5a06a8e0536e3ea9ec60e4c7ac486755e5fb6e6ea9b3500106 \
--hash=sha256:fdd188c8a6ef8769f148f88f859884507b954cc64db6b52f66ef199bb9ad660a \
--hash=sha256:fe913f20024eb2cb2f323e42a64bdf2911bb9738a15dba7d3cce48151034e3a8
cryptography==41.0.0 \
--hash=sha256:0ddaee209d1cf1f180f1efa338a68c4621154de0afaef92b89486f5f96047c55 \
--hash=sha256:14754bcdae909d66ff24b7b5f166d69340ccc6cb15731670435efd5719294895 \
--hash=sha256:344c6de9f8bda3c425b3a41b319522ba3208551b70c2ae00099c205f0d9fd3be \
--hash=sha256:34d405ea69a8b34566ba3dfb0521379b210ea5d560fafedf9f800a9a94a41928 \
--hash=sha256:3680248309d340fda9611498a5319b0193a8dbdb73586a1acf8109d06f25b92d \
--hash=sha256:3c5ef25d060c80d6d9f7f9892e1d41bb1c79b78ce74805b8cb4aa373cb7d5ec8 \
--hash=sha256:4ab14d567f7bbe7f1cdff1c53d5324ed4d3fc8bd17c481b395db224fb405c237 \
--hash=sha256:5c1f7293c31ebc72163a9a0df246f890d65f66b4a40d9ec80081969ba8c78cc9 \
--hash=sha256:6b71f64beeea341c9b4f963b48ee3b62d62d57ba93eb120e1196b31dc1025e78 \
--hash=sha256:7d92f0248d38faa411d17f4107fc0bce0c42cae0b0ba5415505df72d751bf62d \
--hash=sha256:8362565b3835ceacf4dc8f3b56471a2289cf51ac80946f9087e66dc283a810e0 \
--hash=sha256:84a165379cb9d411d58ed739e4af3396e544eac190805a54ba2e0322feb55c46 \
--hash=sha256:88ff107f211ea696455ea8d911389f6d2b276aabf3231bf72c8853d22db755c5 \
--hash=sha256:9f65e842cb02550fac96536edb1d17f24c0a338fd84eaf582be25926e993dde4 \
--hash=sha256:a4fc68d1c5b951cfb72dfd54702afdbbf0fb7acdc9b7dc4301bbf2225a27714d \
--hash=sha256:b7f2f5c525a642cecad24ee8670443ba27ac1fab81bba4cc24c7b6b41f2d0c75 \
--hash=sha256:b846d59a8d5a9ba87e2c3d757ca019fa576793e8758174d3868aecb88d6fc8eb \
--hash=sha256:bf8fc66012ca857d62f6a347007e166ed59c0bc150cefa49f28376ebe7d992a2 \
--hash=sha256:f5d0bf9b252f30a31664b6f64432b4730bb7038339bd18b1fafe129cfc2be9be
# via
# gcp-releasetool
# secretstorage
2 changes: 1 addition & 1 deletion .release-please-manifest.json
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
{
".": "2.20.0"
".": "2.21.0"
}

12 changes: 12 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -4,6 +4,18 @@

[1]: https://pypi.org/project/google-cloud-bigquery-storage/#history

## [2.21.0](https://github.com/googleapis/python-bigquery-storage/compare/v2.20.0...v2.21.0) (2023-07-04)


### Features

* Add estimated physical file sizes to ReadAPI v1 ([#605](https://github.com/googleapis/python-bigquery-storage/issues/605)) ([ad342fe](https://github.com/googleapis/python-bigquery-storage/commit/ad342fe91e3e5c6563f87770aed55d686ae24466))


### Bug Fixes

* Add async context manager return types ([#610](https://github.com/googleapis/python-bigquery-storage/issues/610)) ([e7069d1](https://github.com/googleapis/python-bigquery-storage/commit/e7069d17c32927e33bb905be147a75f7404929fc))

## [2.20.0](https://github.com/googleapis/python-bigquery-storage/compare/v2.19.1...v2.20.0) (2023-05-25)


2 changes: 1 addition & 1 deletion google/cloud/bigquery_storage/gapic_version.py
Original file line number Diff line number Diff line change
@@ -13,4 +13,4 @@
# See the License for the specific language governing permissions and
# limitations under the License.
#
__version__ = "2.20.0" # {x-release-please-version}
__version__ = "2.21.0" # {x-release-please-version}
2 changes: 1 addition & 1 deletion google/cloud/bigquery_storage_v1/gapic_version.py
Original file line number Diff line number Diff line change
@@ -13,4 +13,4 @@
# See the License for the specific language governing permissions and
# limitations under the License.
#
__version__ = "2.20.0" # {x-release-please-version}
__version__ = "2.21.0" # {x-release-please-version}
Original file line number Diff line number Diff line change
@@ -612,7 +612,7 @@ async def sample_split_read_stream():
# Done; return the response.
return response

async def __aenter__(self):
async def __aenter__(self) -> "BigQueryReadAsyncClient":
return self

async def __aexit__(self, exc_type, exc, tb):
Original file line number Diff line number Diff line change
@@ -946,7 +946,7 @@ async def sample_flush_rows():
# Done; return the response.
return response

async def __aenter__(self):
async def __aenter__(self) -> "BigQueryWriteAsyncClient":
return self

async def __aexit__(self, exc_type, exc, tb):
23 changes: 18 additions & 5 deletions google/cloud/bigquery_storage_v1/types/stream.py
Original file line number Diff line number Diff line change
@@ -134,6 +134,15 @@ class ReadSession(proto.Message):
are completely consumed. This estimate is based
on metadata from the table which might be
incomplete or stale.
estimated_total_physical_file_size (int):
Output only. A pre-projected estimate of the
total physical size (in bytes) of files this
session will scan when all streams are
completely consumed. This estimate does not
depend on the selected columns and can be based
on metadata from the table which might be
incomplete or stale. Only set for BigLake
tables.
estimated_row_count (int):
Output only. An estimate on the number of
rows present in this session's streams. This
@@ -233,11 +242,11 @@ class TableReadOptions(proto.Message):
sample_percentage (float):
Optional. Specifies a table sampling percentage.
Specifically, the query planner will use TABLESAMPLE SYSTEM
(sample_percentage PERCENT). This samples at the file-level.
It will randomly choose for each file whether to include
that file in the sample returned. Note, that if the table
only has one file, then TABLESAMPLE SYSTEM will select that
file and return all returnable rows contained within.
(sample_percentage PERCENT). The sampling percentage is
applied at the data block granularity. It will randomly
choose for each data block whether to read the rows in that
data block. For more details, see
https://cloud.google.com/bigquery/docs/table-sampling)
This field is a member of `oneof`_ ``_sample_percentage``.
"""
@@ -317,6 +326,10 @@ class TableReadOptions(proto.Message):
proto.INT64,
number=12,
)
estimated_total_physical_file_size: int = proto.Field(
proto.INT64,
number=15,
)
estimated_row_count: int = proto.Field(
proto.INT64,
number=14,
2 changes: 1 addition & 1 deletion google/cloud/bigquery_storage_v1beta2/gapic_version.py
Original file line number Diff line number Diff line change
@@ -13,4 +13,4 @@
# See the License for the specific language governing permissions and
# limitations under the License.
#
__version__ = "2.20.0" # {x-release-please-version}
__version__ = "2.21.0" # {x-release-please-version}
Original file line number Diff line number Diff line change
@@ -615,7 +615,7 @@ async def sample_split_read_stream():
# Done; return the response.
return response

async def __aenter__(self):
async def __aenter__(self) -> "BigQueryReadAsyncClient":
return self

async def __aexit__(self, exc_type, exc, tb):
Original file line number Diff line number Diff line change
@@ -918,7 +918,7 @@ async def sample_flush_rows():
# Done; return the response.
return response

async def __aenter__(self):
async def __aenter__(self) -> "BigQueryWriteAsyncClient":
return self

async def __aexit__(self, exc_type, exc, tb):
5 changes: 2 additions & 3 deletions noxfile.py
Original file line number Diff line number Diff line change
@@ -315,10 +315,9 @@ def docfx(session):

session.install("-e", ".")
session.install(
"sphinx==4.0.1",
"gcp-sphinx-docfx-yaml",
"alabaster",
"recommonmark",
"gcp-sphinx-docfx-yaml",
)

shutil.rmtree(os.path.join("docs", "_build"), ignore_errors=True)
@@ -390,6 +389,7 @@ def prerelease_deps(session):
"grpcio!=1.52.0rc1",
"grpcio-status",
"google-api-core",
"google-auth",
"proto-plus",
"google-cloud-testutils",
# dependencies of google-cloud-testutils"
@@ -402,7 +402,6 @@ def prerelease_deps(session):
# Remaining dependencies
other_deps = [
"requests",
"google-auth",
]
session.install(*other_deps)

Original file line number Diff line number Diff line change
@@ -8,7 +8,7 @@
],
"language": "PYTHON",
"name": "google-cloud-bigquery-storage",
"version": "2.20.0"
"version": "2.21.0"
},
"snippets": [
{
Original file line number Diff line number Diff line change
@@ -8,7 +8,7 @@
],
"language": "PYTHON",
"name": "google-cloud-bigquery-storage",
"version": "2.20.0"
"version": "2.21.0"
},
"snippets": [
{
2 changes: 1 addition & 1 deletion samples/quickstart/requirements-test.txt
Original file line number Diff line number Diff line change
@@ -1 +1 @@
pytest==7.3.1
pytest==7.3.2
2 changes: 1 addition & 1 deletion samples/quickstart/requirements.txt
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
fastavro
google-cloud-bigquery-storage==2.19.1
google-cloud-bigquery-storage==2.20.0
2 changes: 1 addition & 1 deletion samples/snippets/requirements-test.txt
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
google-cloud-testutils==1.3.3
pytest==7.3.1
pytest==7.3.2
4 changes: 2 additions & 2 deletions samples/snippets/requirements.txt
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
google-cloud-bigquery-storage==2.19.1
google-cloud-bigquery==3.10.0
google-cloud-bigquery-storage==2.20.0
google-cloud-bigquery==3.11.1
2 changes: 1 addition & 1 deletion samples/to_dataframe/requirements-test.txt
Original file line number Diff line number Diff line change
@@ -1 +1 @@
pytest==7.3.1
pytest==7.3.2
12 changes: 6 additions & 6 deletions samples/to_dataframe/requirements.txt
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
google-auth==2.17.3
google-cloud-bigquery-storage==2.19.1
google-cloud-bigquery==3.10.0
pyarrow==11.0.0
google-auth==2.20.0
google-cloud-bigquery-storage==2.20.0
google-cloud-bigquery==3.11.1
pyarrow==12.0.1
ipython===7.31.1; python_version == '3.7'
ipython===8.10.0; python_version == '3.8'
ipython==8.12.0; python_version >= '3.9'
ipython==8.14.0; python_version >= '3.9'
ipywidgets==8.0.6
pandas===1.3.5; python_version == '3.7'
pandas==2.0.0; python_version > '3.7'
pandas==2.0.2; python_version > '3.7'
tqdm==4.65.0
db-dtypes==1.1.1
5 changes: 4 additions & 1 deletion tests/unit/gapic/bigquery_storage_v1/test_big_query_read.py
Original file line number Diff line number Diff line change
@@ -702,9 +702,9 @@ def test_create_read_session(request_type, transport: str = "grpc"):
data_format=stream.DataFormat.AVRO,
table="table_value",
estimated_total_bytes_scanned=3076,
estimated_total_physical_file_size=3608,
estimated_row_count=2047,
trace_id="trace_id_value",
avro_schema=avro.AvroSchema(schema="schema_value"),
)
response = client.create_read_session(request)

@@ -719,6 +719,7 @@ def test_create_read_session(request_type, transport: str = "grpc"):
assert response.data_format == stream.DataFormat.AVRO
assert response.table == "table_value"
assert response.estimated_total_bytes_scanned == 3076
assert response.estimated_total_physical_file_size == 3608
assert response.estimated_row_count == 2047
assert response.trace_id == "trace_id_value"

@@ -765,6 +766,7 @@ async def test_create_read_session_async(
data_format=stream.DataFormat.AVRO,
table="table_value",
estimated_total_bytes_scanned=3076,
estimated_total_physical_file_size=3608,
estimated_row_count=2047,
trace_id="trace_id_value",
)
@@ -782,6 +784,7 @@ async def test_create_read_session_async(
assert response.data_format == stream.DataFormat.AVRO
assert response.table == "table_value"
assert response.estimated_total_bytes_scanned == 3076
assert response.estimated_total_physical_file_size == 3608
assert response.estimated_row_count == 2047
assert response.trace_id == "trace_id_value"

Original file line number Diff line number Diff line change
@@ -703,7 +703,6 @@ def test_create_read_session(request_type, transport: str = "grpc"):
name="name_value",
data_format=stream.DataFormat.AVRO,
table="table_value",
avro_schema=avro.AvroSchema(schema="schema_value"),
)
response = client.create_read_session(request)