Sam Rohde created BEAM-10956:
--------------------------------
Summary: PipelineInstrumentTest is flaky
Key: BEAM-10956
URL: https://issues.apache.org/jira/browse/BEAM-10956
Project: Beam
Issue Type: Improvement
Components: runner-py-interactive
Reporter: Sam Rohde
Assignee: Sam Rohde
h3. Error Message
AttributeError: 'Pipeline' object has no attribute 'pipeline'
h3. Stacktrace
self =
<apache_beam.runners.interactive.pipeline_instrument_test.PipelineInstrumentTest
testMethod=test_pipeline_pruned_when_input_pcoll_is_cached> def
test_pipeline_pruned_when_input_pcoll_is_cached(self): > user_pipeline,
init_pcoll, _ = self._example_pipeline()
apache_beam/runners/interactive/pipeline_instrument_test.py:765: _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
apache_beam/runners/interactive/pipeline_instrument_test.py:223: in
_example_pipeline ie.current_env().set_cache_manager(InMemoryCache(), p)
apache_beam/runners/interactive/interactive_environment.py:324: in
set_cache_manager self.cleanup(pipeline)
apache_beam/runners/interactive/interactive_environment.py:277: in cleanup
self.evict_computed_pcollections(pipeline) _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ self =
<apache_beam.runners.interactive.interactive_environment.InteractiveEnvironment
object at 0x7f8698c89cf8> pipeline = <apache_beam.pipeline.Pipeline object at
0x7f86cc1539e8> def evict_computed_pcollections(self, pipeline=None): """Evicts
all computed PCollections for the given pipeline. If no pipeline is specified,
evicts for all pipelines. """ if pipeline: discarded = set() for pcoll in
self._computed_pcolls: > if pcoll.pipeline is pipeline: E AttributeError:
'Pipeline' object has no attribute 'pipeline'
apache_beam/runners/interactive/interactive_environment.py:506: AttributeError
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
