foster/denoland-deno
0
0
Fork 0
mirror of https://github.com/denoland/deno.git synced 2025-02-01 20:25:12 -05:00
Code Issues Packages 1 Wiki Activity

chore(kv) fix flaky queue test (#19495)

Browse source
This commit is contained in:
Igor Zinkovsky 2023-06-14 07:14:32 -07:00 • committed by Bartek Iwańczuk
parent 0276a38927
commit 1e725e6fd5
No known key found for this signature in database
GPG key ID: 0C6BCDDC3B3AD750
1 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
cli/tests/unit/kv_test.ts
View file

@ -1698,9 +1698,9 @@ Deno.test({
Deno.test({
name: "queue persistence with delay messages",
sanitizeOps: false,
sanitizeResources: false,
async fn() {
const dispatchedPre = Deno.metrics().opsDispatchedAsync;
const completedPre = Deno.metrics().opsCompletedAsync;
const filename = "cli/tests/testdata/queue.db";
try {
await Deno.remove(filename);
@ -1745,6 +1745,14 @@ Deno.test({
db.close();
await listener;
} finally {
// Wait until callbacks are drained before deleting the db.
let dispatched = Deno.metrics().opsDispatchedAsync - dispatchedPre;
let completed = Deno.metrics().opsCompletedAsync - completedPre;
while (dispatched !== completed) {
dispatched = Deno.metrics().opsDispatchedAsync - dispatchedPre;
completed = Deno.metrics().opsCompletedAsync - completedPre;
await sleep(100);
}
await Deno.remove(filename);
}
},