From 5239af08e9bae31d49c2d0ee870290ba07e00542 Mon Sep 17 00:00:00 2001 From: Sam Artuso Date: Wed, 24 Jan 2024 12:17:09 +0000 Subject: [PATCH] fix --- .../src/lib/transactional-adapter-pg-promise.ts | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/packages/transactional-adapters/transactional-adapter-pg-promise/src/lib/transactional-adapter-pg-promise.ts b/packages/transactional-adapters/transactional-adapter-pg-promise/src/lib/transactional-adapter-pg-promise.ts index c221922..dcea08b 100644 --- a/packages/transactional-adapters/transactional-adapter-pg-promise/src/lib/transactional-adapter-pg-promise.ts +++ b/packages/transactional-adapters/transactional-adapter-pg-promise/src/lib/transactional-adapter-pg-promise.ts @@ -27,14 +27,13 @@ export class TransactionalAdapterPgPromise fn: (...args: any[]) => Promise, setClient: (client?: PgPromiseDbOrTx) => void, ) => { - const txCb = (tx: ITask) => { - setClient(tx); - return fn(); - }; - const txArgs = options - ? ([options, txCb] as const) - : ([txCb] as const); - return pgPromiseDbOrTxInstance.tx.apply(null, txArgs); + return pgPromiseDbOrTxInstance.tx( + options ?? {}, + (tx: ITask) => { + setClient(tx); + return fn(); + }, + ); }, getFallbackInstance: () => pgPromiseDbOrTxInstance, });