downloads: adapt reset tests to prepared publication

2026-11-15 00:42:54 +01:00 · 2026-11-14 12:05:29 +00:00
parent e4d97f7aba
commit 35f4f9178b
1 changed files with 5 additions and 1 deletions
@@ -1744,7 +1744,10 @@ class DownloadRepositoryTest {
                    queues.snapshot().resetVersion
                }
            val firstReset = CountDownLatch(1)
-            queues.setResetListener { firstReset.countDown() }
+            queues.setResetListener {
+                firstReset.countDown()
+                QueueResetPreparation(it.snapshot)
+            }
            file(1, "s2").delete()
            file(1, "s3").delete()
            engine.beforeDownload = { engineId ->
@@ -1881,6 +1884,7 @@ class DownloadRepositoryTest {
            queues.setResetListener {
                localUriAtReset.set(repository.localUri("s1"))
                reset.countDown()
+                QueueResetPreparation(it.snapshot)
            }
            val reconciling = launch(Dispatchers.IO) { repository.reconcile() }
            assertTrue(reconciliationStarted.await(5, TimeUnit.SECONDS))