Skip to content

Commit 3ec836e

Browse files
committed
clarify docs; address nit
1 parent 1cbf9c2 commit 3ec836e

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

sdks/python/apache_beam/io/external/xlang_bigqueryio_it_test.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -262,7 +262,7 @@ def run_streaming(self, table_name, num_streams=0, use_at_least_once=False):
262262
streaming=True,
263263
allow_unsafe_triggers=True)
264264

265-
auto_sharding = num_streams == 0
265+
auto_sharding = (num_streams == 0)
266266
with beam.Pipeline(argv=args) as p:
267267
_ = (
268268
p

website/www/site/content/en/documentation/io/built-in/google-bigquery.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -788,7 +788,7 @@ BigQuery Storage Write API for Python SDK currently has some limitations on supp
788788
{{< paragraph class="language-py" >}}
789789
**Note:** If you want to run WriteToBigQuery with Storage Write API from the source code, you need to run `./gradlew :sdks:java:io:google-cloud-platform:expansion-service:build` to build the expansion-service jar. If you are running from a released Beam SDK, the jar will already be included.
790790

791-
**Note:** Auto sharding is not currently supported for Python's Storage Write API.
791+
**Note:** Auto sharding is not currently supported for Python's Storage Write API exactly-once mode on DataflowRunner.
792792

793793
{{< /paragraph >}}
794794

0 commit comments

Comments
 (0)