diff --git a/packages/backend-common/src/database/connectors/postgres.ts b/packages/backend-common/src/database/connectors/postgres.ts index 7dab81dcbb..afc8c207be 100644 --- a/packages/backend-common/src/database/connectors/postgres.ts +++ b/packages/backend-common/src/database/connectors/postgres.ts @@ -42,10 +42,8 @@ export function createPgDatabaseClient( if (role) { database.client.pool.on( 'createSuccess', - (_event: number, pgClient: Client) => { - pgClient.query(`SET ROLE ${role}`, (err: Error, _res: any) => { - if (err) throw err; - }); + async (_event: number, pgClient: Client) => { + await pgClient.query(`SET ROLE ${role}`); }, ); }