Skip to content

Commit

Permalink
cloud_storage/ducktape: Wait for chunk obs. to stop
Browse files Browse the repository at this point in the history
Tests which use chunk observer should wait for it to stop after the stop
command is issued, to avoid the underlying set changing while it is
being read from.

(cherry picked from commit 524a230)
  • Loading branch information
abhijat authored and vbotbuildovich committed Oct 12, 2023
1 parent cdacce9 commit d4fb1f3
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions tests/rptest/tests/cloud_storage_chunk_read_path_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -346,6 +346,9 @@ def test_read_when_cache_smaller_than_segment_size(self):

self._consume_baseline(timeout=180, max_msgs=read_count)
observe_cache_dir.stop()
observe_cache_dir.join(timeout=10)
assert not observe_cache_dir.is_alive(
), 'cache observer is unexpectedly alive'

self._assert_not_in_cache(fr'.*kafka/{self.topic}/.*\.log\.[0-9]+$')
self._assert_in_cache(f'.*kafka/{self.topic}/.*_chunks/[0-9]+')
Expand Down

0 comments on commit d4fb1f3

Please sign in to comment.