You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by go...@apache.org on 2020/01/28 02:22:14 UTC

[beam] branch master updated (0a37f19 -> d1b70d6)

This is an automated email from the ASF dual-hosted git repository.

goenka pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 0a37f19  Merge pull request #10697 from angoenka/fix_lint
     add d1b70d6  [BEAM-8626] Implement status fn api handler in python sdk (#10598)

No new revisions were added by this update.

Summary of changes:
 .../apache_beam/runners/worker/data_plane_test.py  |  26 +---
 .../apache_beam/runners/worker/sdk_worker.py       |  18 ++-
 .../apache_beam/runners/worker/sdk_worker_main.py  |  29 ++--
 .../runners/worker/sdk_worker_main_test.py         |   4 +-
 .../apache_beam/runners/worker/worker_status.py    | 148 +++++++++++++++++++++
 .../runners/worker/worker_status_test.py           |  92 +++++++++++++
 sdks/python/apache_beam/testing/util.py            |  42 ++++++
 7 files changed, 313 insertions(+), 46 deletions(-)
 create mode 100644 sdks/python/apache_beam/runners/worker/worker_status.py
 create mode 100644 sdks/python/apache_beam/runners/worker/worker_status_test.py