diff --git a/packages/common/infra/src/sync/job/impl/indexeddb/index.ts b/packages/common/infra/src/sync/job/impl/indexeddb/index.ts index 3d0799f101..879d5dcd49 100644 --- a/packages/common/infra/src/sync/job/impl/indexeddb/index.ts +++ b/packages/common/infra/src/sync/job/impl/indexeddb/index.ts @@ -238,6 +238,7 @@ export class IndexedDBJobQueue implements JobQueue { throttleTime(300, undefined, { leading: true, trailing: true }), exhaustMapWithTrailing(() => fromPromise(async () => { + await this.ensureInitialized(); const trx = this.database.transaction(['jobs'], 'readonly'); const remaining = await trx.objectStore('jobs').count(); return { remaining };