verify correct files are compressed and uploaded in test_startup_walk…

…_skip_compression_if_already_compressed
Aiven-Open · Jul 4, 2023 · 60d6bf6 · 60d6bf6
1 parent db82d1a
commit 60d6bf6
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/test/test_pghoard.py b/test/test_pghoard.py
@@ -806,8 +806,12 @@ def test_startup_walk_skip_compression_if_already_compressed(
 
         # only one file should be added for compression (invalid compressed one)
         assert self.pghoard.compression_queue.qsize() == 1
+        compression_event = self.pghoard.compression_queue.get()
+        assert compression_event.file_path.name == invalid_compressed_file_name
 
         assert self.pghoard.transfer_queue.qsize() == 1
+        upload_event = self.pghoard.transfer_queue.get()
+        assert upload_event.file_path.name == file_name
 
         if file_type is FileType.Wal:
             assert self.pghoard.wal_file_deletion_queue.qsize() == 1