Skip to content

Commit d674520

Browse files
author
Sam Rohde
committed
Change-Id: Ied7a07ce16ebb1e155692666335a6dae498a01ea
1 parent 1a09a75 commit d674520

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

sdks/python/apache_beam/runners/interactive/pipeline_instrument_test.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -278,8 +278,7 @@ def test_instrument_example_pipeline_to_read_cache(self):
278278
second_pcoll_cache_key = self.cache_key_of('second_pcoll', second_pcoll)
279279
self._mock_write_cache(p_origin, [b'1', b'4', b'9'], second_pcoll_cache_key)
280280
# Mark the completeness of PCollections from the original(user) pipeline.
281-
ie.current_env().mark_pcollection_computed(
282-
(p_origin, init_pcoll, second_pcoll))
281+
ie.current_env().mark_pcollection_computed((init_pcoll, second_pcoll))
283282
instr.build_pipeline_instrument(p_copy)
284283

285284
cached_init_pcoll = (

0 commit comments

Comments
 (0)