[jira] [Created] (BEAM-10956) PipelineInstrumentTest is flaky

["Sam Rohde (Jira)" <ji...@apache.org>]

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)