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 2018/10/04 11:16:02 UTC

[beam] branch master updated (0ce9eac -> 302a842)

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 0ce9eac  Merge pull request #6537: [BEAM-4176] Store and serve termination state after portable job termination
     add c597df7  [BEAM-4660] Add well known timer coder for Python SDK.
     add cf85ded  [BEAM-2687] Implement timers in Python SDK harness.
     add 302a842  Merge pull request #6433 [BEAM-2687] Implement Timers over the Fn API.

No new revisions were added by this update.

Summary of changes:
 sdks/python/apache_beam/coders/coder_impl.py       |  18 +++
 sdks/python/apache_beam/coders/coders.py           |  28 +++++
 .../apache_beam/coders/coders_test_common.py       |   9 ++
 .../apache_beam/coders/standard_coders_test.py     |   9 +-
 .../runners/portability/fn_api_runner.py           | 131 ++++++++++++++++++++-
 .../runners/portability/fn_api_runner_test.py      |  23 ++++
 .../apache_beam/runners/worker/bundle_processor.py | 109 ++++++++++++++---
 .../apache_beam/runners/worker/data_plane.py       |   3 +-
 .../apache_beam/runners/worker/operations.pxd      |   2 +
 .../apache_beam/runners/worker/operations.py       |  18 ++-
 10 files changed, 325 insertions(+), 25 deletions(-)