Skip to content

Commit

Permalink
clarify docs; address nit
Browse files Browse the repository at this point in the history
  • Loading branch information
ahmedabu98 committed Sep 22, 2023
1 parent 1cbf9c2 commit 3ec836e
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -262,7 +262,7 @@ def run_streaming(self, table_name, num_streams=0, use_at_least_once=False):
streaming=True,
allow_unsafe_triggers=True)

auto_sharding = num_streams == 0
auto_sharding = (num_streams == 0)
with beam.Pipeline(argv=args) as p:
_ = (
p
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -788,7 +788,7 @@ BigQuery Storage Write API for Python SDK currently has some limitations on supp
{{< paragraph class="language-py" >}}
**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.

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

{{< /paragraph >}}

Expand Down

0 comments on commit 3ec836e

Please sign in to comment.