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

Posted to commits@beam.apache.org by bh...@apache.org on 2020/11/24 23:35:14 UTC

[beam] branch master updated (bd825f5 -> d7655c1)

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

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


    from bd825f5  [BEAM-11324] Add additional verification in PartitioningSession (#13401)
     add d7655c1  [BEAM-10921]: Fix BEAM-10921 and underlying issues (#13335)

No new revisions were added by this update.

Summary of changes:
 sdks/python/apache_beam/pipeline.py                | 12 +++--
 .../runners/interactive/background_caching_job.py  | 11 ++--
 .../interactive/background_caching_job_test.py     | 42 +++++++++++----
 .../runners/interactive/interactive_environment.py | 49 ++++++++++++++---
 .../runners/interactive/interactive_runner.py      |  4 +-
 .../runners/interactive/interactive_runner_test.py |  3 --
 .../runners/interactive/pipeline_fragment.py       |  9 +++-
 .../runners/interactive/pipeline_instrument.py     | 29 +++++-----
 .../runners/interactive/recording_manager.py       | 20 ++++---
 .../runners/interactive/recording_manager_test.py  | 61 +++++++++-------------
 .../runners/interactive/user_pipeline_tracker.py   | 19 ++++++-
 .../interactive/user_pipeline_tracker_test.py      | 26 +++++++++
 12 files changed, 194 insertions(+), 91 deletions(-)