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/10/05 21:36:21 UTC
[beam] branch master updated (cfe8109 -> 8a1406d)
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 cfe8109 [BEAM-10848] Initialize gauge to 0 (#12992)
add 7812f92 tox: allow apps that support color to use it.
add c0c7c68 [BEAM-7746] Fix typing in beam.utils
add 7385641 [BEAM-7746] Get mypy passing on runners.worker
add 8a1406d Merge pull request #12881 [BEAM-7746] Get mypy passing on runners.worker
No new revisions were added by this update.
Summary of changes:
.../apache_beam/runners/worker/bundle_processor.py | 99 ++++++++------
.../apache_beam/runners/worker/data_plane.py | 119 +++++++++++++----
.../apache_beam/runners/worker/log_handler.py | 30 ++++-
sdks/python/apache_beam/runners/worker/logger.py | 37 +++---
.../apache_beam/runners/worker/opcounters.py | 3 +-
.../apache_beam/runners/worker/operations.py | 26 +++-
.../apache_beam/runners/worker/sdk_worker.py | 146 ++++++++++++++++-----
.../apache_beam/runners/worker/sdk_worker_test.py | 2 +-
.../apache_beam/runners/worker/sideinputs.py | 3 +-
.../apache_beam/runners/worker/statecache.py | 54 ++++++--
.../apache_beam/runners/worker/worker_status.py | 3 +-
.../apache_beam/utils/{__init__.py => sentinel.py} | 15 ++-
sdks/python/apache_beam/utils/timestamp.py | 27 ++++
sdks/python/apache_beam/utils/urns.py | 3 +-
sdks/python/apache_beam/utils/windowed_value.py | 2 +-
sdks/python/mypy.ini | 3 -
sdks/python/tox.ini | 2 +
17 files changed, 422 insertions(+), 152 deletions(-)
copy sdks/python/apache_beam/utils/{__init__.py => sentinel.py} (86%)