tvalentyn commented on PR #25726:
URL: https://github.com/apache/beam/pull/25726#issuecomment-1464797027
> ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Commit/1030 is
potentially an error or flake caused by the PR.
Passed after re-run.
not reproducible in 100 runs but posting here for the record in case it
comes up again
```
Error Message
AssertionError: 0 not greater than 0
Stacktrace
self =
<apache_beam.runners.interactive.recording_manager_test.RecordingManagerTest
testMethod=test_clear_specific_pipeline>
def test_clear_specific_pipeline(self):
"""Tests that clear can empty the cache for a specific pipeline."""
# Create two pipelines so we can check that clearing the cache won't
clear
# all defined pipelines.
p1 = beam.Pipeline(InteractiveRunner())
elems_1 = p1 | 'elems 1' >> beam.Create([0, 1, 2])
p2 = beam.Pipeline(InteractiveRunner())
elems_2 = p2 | 'elems 2' >> beam.Create([0, 1, 2])
# Watch the pipeline and PCollections. This is normally done in a
notebook
# environment automatically, but we have to do it manually here.
ib.watch(locals())
ie.current_env().track_user_pipelines()
# Create the recording objects. By calling `record` a new
PipelineFragment
# is started to compute the given PCollections and cache to disk.
rm_1 = RecordingManager(p1)
recording = rm_1.record([elems_1], max_n=3, max_duration=500)
recording.wait_until_finish()
rm_2 = RecordingManager(p2)
recording = rm_2.record([elems_2], max_n=3, max_duration=500)
recording.wait_until_finish()
# Assert that clearing only one recording clears that recording.
if rm_1.describe()['state'] == PipelineState.STOPPED \
and rm_2.describe()['state'] == PipelineState.STOPPED:
> self.assertGreater(rm_1.describe()['size'], 0)
E AssertionError: 0 not greater than 0
apache_beam/runners/interactive/recording_manager_test.py:472: AssertionError
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
