diff --git a/waku/common/databases/db_postgres/pgasyncpool.nim b/waku/common/databases/db_postgres/pgasyncpool.nim index 13beeb24e..6761d42cc 100644 --- a/waku/common/databases/db_postgres/pgasyncpool.nim +++ b/waku/common/databases/db_postgres/pgasyncpool.nim @@ -170,10 +170,12 @@ proc pgQuery*( let connIndex = (await pool.getConnIndex()).valueOr: return err("connRes.isErr in query: " & $error) - debug "pgQuery", conns = $pool.conns - let queryStartTime = getNowInNanosecondTime() let conn = pool.conns[connIndex].dbConn + + debug "pgQuery", + conns = $pool.conns, requestId, connIndex, connAddr = cast[uint](addr(conn)) + defer: pool.releaseConn(conn) let queryDuration = getNowInNanosecondTime() - queryStartTime @@ -206,14 +208,15 @@ proc runStmt*( ## rowCallback != nil when it is expected to retrieve info from the database. ## rowCallback == nil for queries that change the database state. - debug "runStmt", conns = $pool.conns - let connIndex = (await pool.getConnIndex()).valueOr: return err("Error in runStmt: " & $error) let conn = pool.conns[connIndex].dbConn let queryStartTime = getNowInNanosecondTime() + debug "runStmt", + conns = $pool.conns, requestId, connIndex, connAddr = cast[uint](addr(conn)) + defer: pool.releaseConn(conn) let queryDuration = getNowInNanosecondTime() - queryStartTime