This is an automated email from the ASF dual-hosted git repository.
ningk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 33cd75f Merge pull request #14465 from KevinGG/BEAM-11045
new 5ddae82 [BEAM-10708] Read/Write Intermediate PCollections
new e45705d Fix lint
new 0e9d4f9 Fix based on comments
new 6d26c75 Added clear method to InMemoryCache because tests might be
flaky when a clear is issued in recording manager tests.
new 719318b Avoid using interactive_environment module in the test
because ie.current_env() is raced by threads/processes in the test environment
on Jenkins.
new dd87e14 Added back the setUp as additional cleanup routine before
each test.
new e4e39e4 Merge pull request #14368 from KevinGG/portable_pin_2
The 31431 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../runners/interactive/augmented_pipeline.py | 132 +++++++++++++++
.../runners/interactive/augmented_pipeline_test.py | 86 ++++++++++
.../runners/interactive/caching/read_cache.py | 148 ++++++++++++++++
.../runners/interactive/caching/read_cache_test.py | 91 ++++++++++
.../runners/interactive/caching/write_cache.py | 188 +++++++++++++++++++++
.../interactive/caching/write_cache_test.py | 85 ++++++++++
.../interactive/testing/test_cache_manager.py | 4 +
7 files changed, 734 insertions(+)
create mode 100644
sdks/python/apache_beam/runners/interactive/augmented_pipeline.py
create mode 100644
sdks/python/apache_beam/runners/interactive/augmented_pipeline_test.py
create mode 100644
sdks/python/apache_beam/runners/interactive/caching/read_cache.py
create mode 100644
sdks/python/apache_beam/runners/interactive/caching/read_cache_test.py
create mode 100644
sdks/python/apache_beam/runners/interactive/caching/write_cache.py
create mode 100644
sdks/python/apache_beam/runners/interactive/caching/write_cache_test.py
