This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/pip/sdks/python/parameterized-gte-0.7.1-and-lt-0.10.0
in repository https://gitbox.apache.org/repos/asf/beam.git
omit 25a688cbf3a Update parameterized requirement in /sdks/python
add 1e306fd7bf0 refactored notebooks (#26018)
add 40382c84130 BigQueryHelpers: log statuses using PrettyString (#26037)
add 9c52e0594d6 Make DetectNewPartitions handle Splits and Merges (#25997)
add be725c8a43a Bump com.avast.gradle:gradle-docker-compose-plugin (#26008)
add 57ac3180fc5 Remove unused checkProto2Syntax from ProtobufUtil.java and
test. (#25885)
add 87a0557fd6d Add pytorch 2.0 tests (#26014)
add e0d8b58f397 new file for bq xlang tests (#26046)
add 004c7f612a5 Add documentation for the auto model updates (#25947)
add 6b006531b07 Adding support for GCS-stored files for consumer config
overrides (#25773)
add dc7a7a02c7a Add partition metadata in error logs in the restriction
tracker for change streams and delete unused files (#26040)
add 5e368b4d7ce Add partition reconciler to handle known cases where
partitions can get stuck (#26045)
add 492e2c95f52 (#25314) Have boot loaders log to logging service where
possible. (#26035)
add af5e0a85cc8 [Go SDK] Update slog in prism to fix breaking changes.
(#26053)
add 40bc89da4c7 Revert "Change the type of Samza Runner MaxBundleSize
pipeline option to match with Flink Runner (#25854)" (#25972)
add 111ce402a12 Bump github.com/opencontainers/runc from 1.1.3 to 1.1.5 in
/sdks (#26028)
add 350356f1a5d Bump github.com/tetratelabs/wazero from 1.0.0-rc.1 to
1.0.1 in /sdks (#26024)
add b8e5c70ab9e Bump google.golang.org/api from 0.112.0 to 0.114.0 in
/sdks (#25900)
add 138f760168b Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks
(#25924)
add 87844539cc9 Bump cloud.google.com/go/bigquery from 1.47.0 to 1.49.0 in
/sdks (#25875)
add f93cb9af531 Bump google.golang.org/protobuf from 1.29.0 to 1.30.0 in
/sdks (#25874)
add 1bdcd1aa94a Merge pull request #26006: Google Cloud libraries BOM
26.11.0
add ed5619033f8 Work around for #26066 in mongodbio. (#26067)
add 7ee74d2bf73 [Go SDK] Update beam infra to Go 1.20.2 (#26054)
add 4b2c03b35b2 Remove myself from Go reviewers (#26076)
add e3eedce8a1e [BEAM-20807] Support Beam Go docker images on ARM64.
(#26047)
add dbf0f18b9e1 Add XGBoost example notebook (#25904)
add dc1ab49975f Bump google.golang.org/grpc from 1.53.0 to 1.54.0 in /sdks
(#26068)
add 6aca49df5b2 Disable FIrestore integration test in Dataflow PostCommits
(#26060)
add 18f6554e198 Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#26072)
add 619dcfab65b Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#26071)
add 30178227c63 Added windowin example (#25905)
add 10a9c0f7c55 Update tensorflow in base image requirements (#26055)
add 0fb9c8cecb7 Remove accidental commit (#26081)
add c90f5b9dd9a Point out that sibling sdk protocol was enabled for Python
custom containers starting 2.46.0. (#26084)
add 65c57342126 Fix compatibility with dill 0.3.6.
add 4f9055d2d7d Reimplement a deleted function.
add 121a46c799e Remove a ParDo definition from a global context to prevent
dill from pickling entire main session.
add c6f2ad2a0ef Fix compatibility with dill 0.3.6. #26086
add 32269b2abb0 [#26061][Go SDK] Return server error on stream close for
artifact upload. (#26062)
add 287eff05c2b Adding support for Spanner Databoost in SpannerIO (#26007)
add 85ef5976c2b (Re)enable ErrorProne, Spotbug and Coverage report in IO
PreCommits (#25956)
add 755ce7b43f1 restore deleted line
add dced7738d6a Merge pull request #26089 from reuvenlax/fix_storage_api
add 48d66ada923 Remove status disclaimer from pydoc root. (#26106)
add c6f8e0be1a5 Implement GetSize for ReadChangeStream to support
autoscaling (#26052)
add e19d305763c Bump cloud.google.com/go/bigquery from 1.49.0 to 1.50.0 in
/sdks (#26094)
add aeebe56720b Clean up some unneccessarily nested ifs in stage.go
(#26119)
add ed93a34524d Bump golang.org/x/sys from 0.6.0 to 0.7.0 in /sdks (#26110)
add e697569b79e [#25887] fix(JmsIO): issue with multiple connection open
#25887 (#25945)
add 18d9b21cf3e DoFn lifecycle JavaDoc update. (#26122)
add 131e5d3adc4 Update dockerhub guidance (#26124)
add e103f776555 Add Python 3.11 for GHA python tests Update python minor
version Add py311 to python tests
add 1ae81cbefee Add use-pep 517 flag
add 1c13aa9f14a Add python 3.11 to test-properties.json Add Python 3.11 to
PostCommit and Precommits that run on Jenkins fix groovy file Add context to a
TODO comment
add 2c47f7cecf0 Add 3.11 to dataflow api_client
add 8be511cc073 Add Python 3.11 to test-suites Add Python 3.11 to tox
add 708010fd644 Add python 3.11 to settings.gradle.kts
add b6dbc9de8ed Add Python 3.11 to doc fix tox task
add 165c82dd219 Update pyarrow version in setup.py, and add tests in tox
fix tox task Update tenacity
add 1acd08f3b83 Update cython version in tox
add 16be446a6fd add conditions for deps for which py311 wheels are not
built
add 3d0ee7b4ccb Monkey-patch dill 0.3.1.1 to support Python 3.11
add 15811379b53 Update base image requirements.
add c6b2800806e Announce Python 3.11 changes
add 87db1ae2c04 Support Python 3.11 (#26121)
add f6d2ce0692a Update parameterized requirement in /sdks/python
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (25a688cbf3a)
\
N -- N -- N
refs/heads/dependabot/pip/sdks/python/parameterized-gte-0.7.1-and-lt-0.10.0
(f6d2ce0692a)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/REVIEWERS.yml | 1 -
.../test-properties.json | 12 +-
.../actions/setup-self-hosted-action/action.yml | 8 +-
.github/workflows/build_wheels.yml | 2 +-
.github/workflows/go_tests.yml | 4 +-
.github/workflows/local_env_tests.yml | 4 +-
.github/workflows/python_tests.yml | 9 +-
.test-infra/jenkins/PythonTestProperties.groovy | 3 +-
.test-infra/jenkins/README.md | 53 +-
.test-infra/jenkins/job_PreCommit_Java.groovy | 100 ++-
.../job_PreCommit_Java_AWS2_IO_Direct.groovy | 43 --
.../job_PreCommit_Java_AWS_IO_Direct.groovy | 44 --
.../job_PreCommit_Java_GCP_IO_Direct.groovy | 18 +-
.../job_PreCommit_Java_Hadoop_IO_Direct.groovy | 49 --
.test-infra/jenkins/job_PreCommit_Java_IOs.groovy | 212 +++--
.../job_PreCommit_Java_Kafka_IO_Direct.groovy | 48 --
.../job_PreCommit_Java_Kinesis_IO_Direct.groovy | 44 --
.../job_PreCommit_Java_MongoDb_IO_Direct.groovy | 43 --
.../jenkins/job_PreCommit_Portable_Python.groovy | 8 +-
.test-infra/jenkins/job_PreCommit_SQL.groovy | 5 +-
CHANGES.md | 8 +-
build.gradle.kts | 20 +-
buildSrc/build.gradle.kts | 2 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 20 +-
.../beam-ml/run_inference_tensorflow.ipynb | 250 ++++--
.../beam-ml/run_inference_tensorflow_hub.ipynb | 560 --------------
...ynb => run_inference_with_tensorflow_hub.ipynb} | 510 +-----------
.../notebooks/beam-ml/run_inference_xgboost.ipynb | 369 +++++++++
.../playground_components/assets/symbols/go.g.yaml | 4 +-
release/go-licenses/Dockerfile | 2 +-
runners/google-cloud-dataflow-java/build.gradle | 5 +
.../beam/runners/samza/SamzaPipelineOptions.java | 8 +-
sdks/go.mod | 61 +-
sdks/go.sum | 141 ++--
sdks/go/container/Dockerfile | 4 +-
sdks/go/container/boot.go | 33 +-
sdks/go/container/boot_test.go | 16 +-
sdks/go/container/build.gradle | 2 +
sdks/go/container/tools/logging.go | 117 +++
sdks/go/container/tools/logging_test.go | 115 +++
.../provision => container/tools}/provision.go | 19 +-
sdks/go/container/tools/provision_test.go | 110 +++
sdks/go/pkg/beam/artifact/stage.go | 14 +-
sdks/go/pkg/beam/io/mongodbio/coder.go | 25 +-
sdks/go/pkg/beam/provision/provision.go | 59 +-
sdks/go/pkg/beam/runners/prism/internal/coders.go | 3 +-
sdks/go/pkg/beam/runners/prism/internal/stage.go | 3 +-
.../beam/runners/prism/internal/worker/worker.go | 9 +-
.../go/pkg/beam/runners/universal/runnerlib/job.go | 4 +-
.../pkg/beam/runners/universal/runnerlib/stage.go | 64 +-
.../beam/runners/universal/runnerlib/stage_test.go | 173 +++++
sdks/go/run_with_go_version.sh | 2 +-
sdks/java/container/boot.go | 47 +-
.../container/license_scripts/dep_urls_java.yaml | 2 +-
sdks/java/core/build.gradle | 9 +
.../beam/sdk/extensions/protobuf/ProtobufUtil.java | 20 -
.../sdk/extensions/protobuf/ProtobufUtilTest.java | 31 -
.../beam/sdk/io/gcp/bigquery/BigQueryHelpers.java | 12 +-
.../bigquery/StorageApiWriteUnshardedRecords.java | 1 +
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 23 +-
.../changestreams/ByteStringRangeHelper.java | 112 ++-
.../ChangeStreamContinuationTokenHelper.java | 47 ++
.../changestreams/ChangeStreamMetrics.java | 36 +
.../bigtable/changestreams/TimestampConverter.java | 4 +
.../changestreams/action/ActionFactory.java | 11 +-
.../changestreams/action/ChangeStreamAction.java | 9 +-
.../action/DetectNewPartitionsAction.java | 228 +++++-
.../action/ReadChangeStreamPartitionAction.java | 35 +-
.../changestreams/dao/MetadataTableDao.java | 112 ++-
.../dofn/ReadChangeStreamPartitionDoFn.java | 57 +-
.../estimator/BytesThroughputEstimator.java | 173 +++++
.../changestreams/estimator/EncodingException.java | 27 +-
.../estimator/NullThroughputEstimator.java | 61 ++
.../changestreams/estimator/SizeEstimator.java | 70 ++
.../ThroughputEstimator.java} | 29 +-
.../changestreams/estimator/package-info.java | 32 +-
.../reconciler/PartitionReconciler.java | 153 ++++
.../changestreams/reconciler/package-info.java | 30 +-
.../changestreams/restriction/StreamProgress.java | 2 +-
.../beam/sdk/io/gcp/spanner/BatchSpannerRead.java | 11 +-
.../beam/sdk/io/gcp/spanner/SpannerAccessor.java | 32 +-
.../beam/sdk/io/gcp/spanner/SpannerConfig.java | 9 +
.../changestreams/restriction/PartitionMode.java | 35 -
.../restriction/PartitionPosition.java | 90 ---
.../restriction/PartitionRestriction.java | 141 ----
.../restriction/PartitionRestrictionClaimer.java | 136 ----
.../restriction/PartitionRestrictionMetadata.java | 106 ---
.../PartitionRestrictionProgressChecker.java | 96 ---
.../restriction/PartitionRestrictionSplitter.java | 128 ---
.../restriction/PartitionRestrictionTracker.java | 159 ----
.../ReadChangeStreamPartitionRangeTracker.java | 2 +-
.../restriction/TimestampRangeTracker.java | 24 +
.../changestreams/ByteStringRangeHelperTest.java | 108 +++
.../ChangeStreamContinuationTokenHelperTest.java | 68 ++
.../changestreams/TimestampConverterTest.java | 6 +
.../action/ChangeStreamActionTest.java | 8 +-
.../action/DetectNewPartitionsActionTest.java | 233 +++++-
.../ReadChangeStreamPartitionActionTest.java | 89 ++-
.../changestreams/dao/MetadataTableDaoTest.java | 45 +-
.../dofn/ReadChangeStreamPartitionDoFnTest.java | 143 ++++
.../estimator/BytesThroughputEstimatorTest.java | 173 +++++
.../estimator/NullThroughputEstimatorTest.java | 40 +-
.../reconciler/PartitionReconcilerTest.java | 195 +++++
.../beam/sdk/io/gcp/spanner/SpannerIOReadTest.java | 47 +-
.../beam/sdk/io/gcp/spanner/SpannerReadIT.java | 26 +
.../restriction/PartitionPositionTest.java | 70 --
.../PartitionRestrictionClaimerTest.java | 272 -------
.../PartitionRestrictionProgressCheckerTest.java | 230 ------
.../PartitionRestrictionSplitterTest.java | 168 ----
.../restriction/PartitionRestrictionTest.java | 78 --
.../PartitionRestrictionTrackerTest.java | 859 ---------------------
.../util/PartitionPositionGenerator.java | 54 --
sdks/java/io/jms/build.gradle | 7 +
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 58 +-
.../apache/beam/sdk/io/jms/RetryConfiguration.java | 5 +
.../java/org/apache/beam/sdk/io/jms/CommonJms.java | 133 ++++
.../java/org/apache/beam/sdk/io/jms/JmsIOIT.java | 305 ++++++++
.../java/org/apache/beam/sdk/io/jms/JmsIOTest.java | 197 +++--
.../io/kafka/KafkaReadSchemaTransformProvider.java | 76 ++
sdks/java/io/pulsar/build.gradle | 5 +-
sdks/java/io/splunk/build.gradle | 2 +-
sdks/python/apache_beam/__init__.py | 7 +-
.../apache_beam/examples/inference/README.md | 43 +-
.../inference/milk_quality_prediction_windowing.py | 240 ++++++
sdks/python/apache_beam/internal/dill_pickler.py | 143 +++-
.../io/external/xlang_bigqueryio_it_test.py | 239 ++++++
.../apache_beam/io/gcp/bigquery_write_it_test.py | 190 -----
.../runners/dataflow/internal/apiclient.py | 2 +-
.../runners/dataflow/internal/apiclient_test.py | 2 +-
sdks/python/apache_beam/transforms/window_test.py | 7 +-
.../container/base_image_requirements_manual.txt | 10 +-
sdks/python/container/boot.go | 62 +-
sdks/python/container/build.gradle | 5 +-
.../container/py310/base_image_requirements.txt | 83 +-
.../{py310 => py311}/base_image_requirements.txt | 87 +--
sdks/python/container/py311/build.gradle | 28 +
.../container/py37/base_image_requirements.txt | 62 +-
.../container/py38/base_image_requirements.txt | 85 +-
.../container/py39/base_image_requirements.txt | 85 +-
sdks/python/setup.py | 7 +-
.../python/test-suites/dataflow/py311/build.gradle | 24 +
sdks/python/test-suites/direct/py311/build.gradle | 24 +
sdks/python/test-suites/gradle.properties | 24 +-
.../python/test-suites/portable/py311/build.gradle | 26 +
sdks/python/test-suites/tox/py311/build.gradle | 32 +
sdks/python/test-suites/tox/py38/build.gradle | 4 +
sdks/python/tox.ini | 45 +-
sdks/typescript/container/boot.go | 39 +-
settings.gradle.kts | 5 +
.../site/content/en/contribute/release-guide.md | 12 +-
.../en/documentation/ml/side-input-updates.md | 143 ++++
.../content/en/documentation/programming-guide.md | 7 +-
.../documentation/sdks/python-machine-learning.md | 19 +-
.../partials/section-menu/en/documentation.html | 1 +
154 files changed, 6007 insertions(+), 5269 deletions(-)
delete mode 100644 .test-infra/jenkins/job_PreCommit_Java_AWS2_IO_Direct.groovy
delete mode 100644 .test-infra/jenkins/job_PreCommit_Java_AWS_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_Hadoop_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_Kafka_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_Kinesis_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_MongoDb_IO_Direct.groovy
delete mode 100644
examples/notebooks/beam-ml/run_inference_tensorflow_hub.ipynb
rename
examples/notebooks/beam-ml/{run_inference_tensorflow_with_tensorflowhub.ipynb
=> run_inference_with_tensorflow_hub.ipynb} (79%)
create mode 100644 examples/notebooks/beam-ml/run_inference_xgboost.ipynb
create mode 100644 sdks/go/container/tools/logging.go
create mode 100644 sdks/go/container/tools/logging_test.go
copy sdks/go/{pkg/beam/provision => container/tools}/provision.go (83%)
create mode 100644 sdks/go/container/tools/provision_test.go
create mode 100644 sdks/go/pkg/beam/runners/universal/runnerlib/stage_test.go
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/ChangeStreamContinuationTokenHelper.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/estimator/BytesThroughputEstimator.java
rename .test-infra/jenkins/job_PreCommit_Java_Azure_IO_Direct.groovy =>
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/estimator/EncodingException.java
(59%)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/estimator/NullThroughputEstimator.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/estimator/SizeEstimator.java
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/{TimestampConverter.java
=> estimator/ThroughputEstimator.java} (51%)
rename .test-infra/jenkins/job_PreCommit_Java_Pulsar_IO_Direct.groovy =>
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/estimator/package-info.java
(58%)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/reconciler/PartitionReconciler.java
rename .test-infra/jenkins/job_PreCommit_Java_Parquet_IO_Direct.groovy =>
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/reconciler/package-info.java
(57%)
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionMode.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionPosition.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestriction.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionClaimer.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionMetadata.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionProgressChecker.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionSplitter.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionTracker.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/ChangeStreamContinuationTokenHelperTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/dofn/ReadChangeStreamPartitionDoFnTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/estimator/BytesThroughputEstimatorTest.java
rename .test-infra/jenkins/job_PreCommit_Java_JDBC_IO_Direct.groovy =>
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/estimator/NullThroughputEstimatorTest.java
(52%)
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/reconciler/PartitionReconcilerTest.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionPositionTest.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionClaimerTest.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionProgressCheckerTest.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionSplitterTest.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionTest.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionTrackerTest.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/util/PartitionPositionGenerator.java
create mode 100644
sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/CommonJms.java
create mode 100644
sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java
create mode 100644
sdks/python/apache_beam/examples/inference/milk_quality_prediction_windowing.py
create mode 100644
sdks/python/apache_beam/io/external/xlang_bigqueryio_it_test.py
copy sdks/python/container/{py310 => py311}/base_image_requirements.txt (72%)
create mode 100644 sdks/python/container/py311/build.gradle
create mode 100644 sdks/python/test-suites/dataflow/py311/build.gradle
create mode 100644 sdks/python/test-suites/direct/py311/build.gradle
create mode 100644 sdks/python/test-suites/portable/py311/build.gradle
create mode 100644 sdks/python/test-suites/tox/py311/build.gradle
create mode 100644
website/www/site/content/en/documentation/ml/side-input-updates.md