You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2020/01/14 21:23:25 UTC
[beam] branch master updated (3891f9f -> d03404d)
This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 3891f9f Merge pull request #10558 [BEAM-6587] Remove hacks due to missing common string coder.
add 2c00922 [BEAM-7746] Address changes in code since annotations were introduced
add 882c865 [BEAM-7746] Typing fixes that require runtime code changes
add bfc6e55 [BEAM-7746] Avoid creating attributes dynamically, so that they can be statically analyzed
add 8353a28 [BEAM-7746] Bugfix: coder id is expected to be str in python3
add 29e243e [BEAM-7746] Explicitly unpack tuple to avoid inferring unbounded tuple (Tuple[str, ...])
add 374db87 [BEAM-7746] Generate files with protobuf urns as part of gen_protos build process
add bc21b25 [BEAM-7746] Move name and coder to base StateSpec class
add 80e2c2e [BEAM-7746] Remove reference to missing attribute in statesampler_slow.StateSampler.reset()
add 9f14ce9 [BEAM-7746] Non-Optional arguments cannot default to None
add ee13d08 [BEAM-7746] Avoid reusing variables with different data types
add 83866ec [BEAM-7746] Add StateHandler abstract base class
add 6189010 [BEAM-7746] Add TODO about fixing assignment to BundleManager._skip_registration
add 3ff01eb [BEAM-7746] Fix functions that were defined twice
add f7f8792 [BEAM-7746] Fix tests that have the same name
add d03404d Merge pull request #10367 [BEAM-7746] Add python type hints (part 2)
No new revisions were added by this update.
Summary of changes:
sdks/python/apache_beam/coders/coder_impl.py | 3 +-
sdks/python/apache_beam/coders/row_coder.py | 2 +-
.../examples/complete/game/game_stats.py | 5 -
sdks/python/apache_beam/io/fileio_test.py | 4 +-
sdks/python/apache_beam/io/filesystems_test.py | 11 +-
sdks/python/apache_beam/io/iobase.py | 6 +
.../apache_beam/io/restriction_trackers_test.py | 7 -
sdks/python/apache_beam/io/tfrecordio_test.py | 19 ++-
sdks/python/apache_beam/io/vcfio.py | 3 -
sdks/python/apache_beam/metrics/cells.py | 25 ++-
sdks/python/apache_beam/pipeline.py | 40 +++--
sdks/python/apache_beam/portability/common_urns.py | 100 ++++-------
.../{internal/__init__.py => portability/utils.py} | 16 +-
sdks/python/apache_beam/pvalue.py | 11 +-
sdks/python/apache_beam/runners/common.py | 39 +++--
.../apache_beam/runners/direct/bundle_factory.py | 7 +-
.../runners/direct/transform_evaluator.py | 1 +
.../python/apache_beam/runners/pipeline_context.py | 42 +++--
.../runners/portability/abstract_job_service.py | 10 +-
.../runners/portability/artifact_service.py | 2 +-
.../runners/portability/fn_api_runner.py | 78 ++++++---
.../portability/fn_api_runner_transforms.py | 29 ++--
.../runners/portability/portable_runner.py | 2 +-
.../apache_beam/runners/worker/bundle_processor.py | 168 +++++++++++++++----
.../apache_beam/runners/worker/operations.py | 4 +
.../apache_beam/runners/worker/sdk_worker.py | 64 ++++++--
.../apache_beam/runners/worker/statecache.py | 15 +-
.../apache_beam/runners/worker/statesampler.py | 12 +-
.../runners/worker/statesampler_slow.py | 3 +-
sdks/python/apache_beam/testing/util_test.py | 2 +-
sdks/python/apache_beam/transforms/combiners.py | 57 ++++---
sdks/python/apache_beam/transforms/core.py | 8 +-
sdks/python/apache_beam/transforms/display.py | 18 +-
sdks/python/apache_beam/transforms/environments.py | 78 ++++++++-
sdks/python/apache_beam/transforms/sideinputs.py | 11 ++
sdks/python/apache_beam/transforms/userstate.py | 33 ++--
.../apache_beam/transforms/userstate_test.py | 4 +-
.../apache_beam/typehints/decorators_test_py3.py | 4 +-
sdks/python/apache_beam/utils/profiler.py | 1 +
.../apache_beam/utils/thread_pool_executor.py | 2 +-
sdks/python/gen_protos.py | 182 ++++++++++++++++++++-
41 files changed, 815 insertions(+), 313 deletions(-)
copy sdks/python/apache_beam/{internal/__init__.py => portability/utils.py} (70%)