This is an automated email from the ASF dual-hosted git repository.
udim pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 60aa5d9 Merge pull request #10559 from
vectorijk/calcite-vendor-jdbc-url
add 7a50378 more typing fixes
add 6ad25c1 Fix typing issue with python 3.5.2
add e5cfa13 fixes
add aaa5fc2 Address more issues discovered after rebase
add 2cdde4a Improve the idiom used for conditional imports
add d63d08f Fix more issues
add 114bbc4 Update to latest mypy version
add 2f10df9 Merge pull request #10822: [BEAM-7746] Minor typing updates /
fixes
No new revisions were added by this update.
Summary of changes:
sdks/python/apache_beam/coders/coders.py | 4 +-
.../python/apache_beam/io/aws/s3filesystem_test.py | 24 ++--
sdks/python/apache_beam/io/aws/s3io.py | 8 +-
sdks/python/apache_beam/io/filesystem.py | 35 +++++-
sdks/python/apache_beam/io/iobase.py | 1 +
sdks/python/apache_beam/pipeline.py | 86 ++++++++++----
sdks/python/apache_beam/pvalue.py | 2 +-
sdks/python/apache_beam/runners/common.py | 31 +++--
.../runners/dataflow/dataflow_runner.py | 9 +-
.../runners/direct/evaluation_context.py | 6 +-
.../runners/direct/sdf_direct_runner.py | 8 +-
.../runners/direct/transform_evaluator.py | 4 +-
.../interactive/background_caching_job_test.py | 2 +-
.../interactive/caching/streaming_cache_test.py | 6 +-
.../display/pcoll_visualization_test.py | 2 +-
.../interactive/display/pipeline_graph_renderer.py | 3 +-
.../interactive/display/pipeline_graph_test.py | 2 +-
.../interactive/interactive_environment_test.py | 2 +-
.../runners/interactive/interactive_runner_test.py | 2 +-
.../interactive/options/capture_control_test.py | 2 +-
.../runners/interactive/pipeline_fragment_test.py | 2 +-
.../runners/portability/abstract_job_service.py | 2 +-
.../runners/portability/fn_api_runner.py | 46 +++++---
.../portability/fn_api_runner_transforms.py | 6 +-
sdks/python/apache_beam/runners/runner.py | 2 +-
sdks/python/apache_beam/runners/sdf_utils.py | 10 +-
.../apache_beam/runners/worker/bundle_processor.py | 37 ++++--
.../apache_beam/runners/worker/data_plane.py | 30 +++--
.../apache_beam/runners/worker/operations.py | 47 +++++---
.../apache_beam/runners/worker/sdk_worker.py | 8 +-
.../testing/test_stream_service_test.py | 6 +-
sdks/python/apache_beam/transforms/combiners.py | 2 +-
sdks/python/apache_beam/transforms/core.py | 14 ++-
sdks/python/apache_beam/transforms/environments.py | 4 +-
sdks/python/apache_beam/transforms/external.py | 2 +-
.../python/apache_beam/transforms/external_java.py | 8 +-
sdks/python/apache_beam/transforms/ptransform.py | 11 +-
sdks/python/apache_beam/transforms/timeutil.py | 6 +-
sdks/python/apache_beam/transforms/trigger.py | 3 +-
sdks/python/apache_beam/transforms/util.py | 9 +-
sdks/python/apache_beam/transforms/window.py | 3 +-
sdks/python/apache_beam/typehints/decorators.py | 11 +-
.../apache_beam/typehints/decorators_test.py | 2 +-
.../apache_beam/typehints/decorators_test_py3.py | 5 +-
sdks/python/apache_beam/typehints/typehints.py | 4 +-
sdks/python/apache_beam/utils/processes.py | 125 +++++++++++----------
sdks/python/apache_beam/utils/proto_utils.py | 8 ++
sdks/python/apache_beam/utils/retry.py | 4 +-
sdks/python/setup.cfg | 2 +
sdks/python/tox.ini | 2 +-
50 files changed, 410 insertions(+), 250 deletions(-)
