[beam] branch master updated: Fix BEAM-10956

[pa...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new d6745206 Fix BEAM-10956
     new 34a2caf  Merge pull request #12922 from [BEAM-10956] Fixes incorrect API usage in PipelineInstrumentTest causing flakiness
d6745206 is described below

commit d674520668ea764ccba0066003ad18ce69126759
Author: Sam Rohde <sr...@google.com>
AuthorDate: Wed Sep 23 12:46:59 2020 -0700

    Fix BEAM-10956
    
    Change-Id: Ied7a07ce16ebb1e155692666335a6dae498a01ea
---
 .../python/apache_beam/runners/interactive/pipeline_instrument_test.py | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/sdks/python/apache_beam/runners/interactive/pipeline_instrument_test.py b/sdks/python/apache_beam/runners/interactive/pipeline_instrument_test.py
index 65ecb97..2ab98ed 100644
--- a/sdks/python/apache_beam/runners/interactive/pipeline_instrument_test.py
+++ b/sdks/python/apache_beam/runners/interactive/pipeline_instrument_test.py
@@ -278,8 +278,7 @@ class PipelineInstrumentTest(unittest.TestCase):
     second_pcoll_cache_key = self.cache_key_of('second_pcoll', second_pcoll)
     self._mock_write_cache(p_origin, [b'1', b'4', b'9'], second_pcoll_cache_key)
     # Mark the completeness of PCollections from the original(user) pipeline.
-    ie.current_env().mark_pcollection_computed(
-        (p_origin, init_pcoll, second_pcoll))
+    ie.current_env().mark_pcollection_computed((init_pcoll, second_pcoll))
     instr.build_pipeline_instrument(p_copy)
 
     cached_init_pcoll = (