diff --git a/src/services/storage/metricsStorage.ts b/src/services/storage/metricsStorage.ts index 622133c6..54c7bbd9 100644 --- a/src/services/storage/metricsStorage.ts +++ b/src/services/storage/metricsStorage.ts @@ -70,7 +70,7 @@ export default class { return } const data = update(newTMPHtlcFailureData()) - await entityManager.getRepository(HtlcFailures).save({ key, value: data }) + await this.txQueue.PushToQueue({ exec: async db => db.getRepository(HtlcFailures).save({ key, value: data }), dbTx: false }) } }