diff options
Diffstat (limited to 'packages/taler-wallet-core/src/shepherd.ts')
| -rw-r--r-- | packages/taler-wallet-core/src/shepherd.ts | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/packages/taler-wallet-core/src/shepherd.ts b/packages/taler-wallet-core/src/shepherd.ts index a54049d7c..f04bcd2c2 100644 --- a/packages/taler-wallet-core/src/shepherd.ts +++ b/packages/taler-wallet-core/src/shepherd.ts @@ -286,6 +286,7 @@ export class TaskSchedulerImpl implements TaskScheduler { async resetTaskRetries(taskId: TaskIdStr): Promise<void> { const maybeNotification = await this.ws.db.runAllStoresReadWriteTx( + {}, async (tx) => { await tx.operationRetries.delete(taskId); return taskToRetryNotification(this.ws, tx, taskId, undefined); @@ -434,7 +435,7 @@ async function storePendingTaskError( e: TalerErrorDetail, ): Promise<OperationRetryRecord> { logger.info(`storing pending task error for ${pendingTaskId}`); - const res = await ws.db.runAllStoresReadWriteTx(async (tx) => { + const res = await ws.db.runAllStoresReadWriteTx({}, async (tx) => { let retryRecord = await tx.operationRetries.get(pendingTaskId); if (!retryRecord) { retryRecord = { @@ -474,7 +475,7 @@ async function storePendingTaskPending( ws: InternalWalletState, pendingTaskId: string, ): Promise<OperationRetryRecord> { - const res = await ws.db.runAllStoresReadWriteTx(async (tx) => { + const res = await ws.db.runAllStoresReadWriteTx({}, async (tx) => { let retryRecord = await tx.operationRetries.get(pendingTaskId); let hadError = false; if (!retryRecord) { |