wait for migrations to complete

1 files changed, 2 insertions, 1 deletions

diff --git a/lib/migrate.js b/lib/migrate.js
index bb87a28b..c64d2549 100644
--- a/lib/migrate.js
+++ b/lib/migrate.js
@@ -1,7 +1,7 @@
 import { err, warn, l, line } from "$lib/logging";
 import { types } from "$lib/payments";
 import { archive, db, g, ga, s } from "$lib/db";
-  import { wait } from "$lib/utils";
+import { wait } from "$lib/utils";
 
 let queued = {};
 let processing = {};
@@ -11,6 +11,7 @@ async function migrate(id) {
   if (processing[id]) await wait(() => !processing[id]);
   delete queued[id];
   processing[id] = true;
+  setTimeout(() => delete processing[id], 10000);
 
   let user = await g(`user:${id}`);
   if (typeof user === "string") user = await g(`user:${user}`);