[
https://issues.apache.org/jira/browse/BEAM-10956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201048#comment-17201048
]
Sam Rohde commented on BEAM-10956:
----------------------------------
Able to repro with `for i in \{1..100}; do python pipeline_instrument_test.py &
done`
> 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
> Priority: P2
>
> 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)
