diff --git a/packages/server/src/appMigrations/index.ts b/packages/server/src/appMigrations/index.ts index 079e3e8c44..ba91d20594 100644 --- a/packages/server/src/appMigrations/index.ts +++ b/packages/server/src/appMigrations/index.ts @@ -11,8 +11,12 @@ export async function checkMissingMigrations(appId: string) { await queue.add( { appId, + }, + { + jobId: appId, + removeOnComplete: true, + removeOnFail: true, } - // TODO: idempotency ) } }