Skip to content

Commit

Permalink
more temporary log
Browse files Browse the repository at this point in the history
  • Loading branch information
Ivansete-status committed Sep 28, 2024
1 parent d3a33da commit c6f3249
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions waku/common/databases/db_postgres/dbconn.nim
Original file line number Diff line number Diff line change
Expand Up @@ -141,11 +141,6 @@ proc waitQueryToFinish(
## The 'rowCallback' param is != nil when the underlying query wants to retrieve results (SELECT.)
## For other queries, like "INSERT", 'rowCallback' should be nil.

for item in pendingFutures():
let loc = item.location[LocCreateIndex][]
let futureId = Base10.toString(item.id)

# debug "pending futures", loc, futureId, count = pendingFuturesCount()
debug "pending futures", count = pendingFuturesCount()

var triggered = false
Expand All @@ -168,6 +163,11 @@ proc waitQueryToFinish(
signal.close().isOkOr:
return err("error closing data available signal: " & $error)

for item in pendingFutures():
let loc = item.location[LocCreateIndex][]
let futureId = Base10.toString(item.id)
debug "pending futures", loc, futureId, count = pendingFuturesCount()

debug "waitQueryToFinish", requestId, connName = db.connName
await signal.wait()
debug "waitQueryToFinish", requestId, connName = db.connName
Expand Down

0 comments on commit c6f3249

Please sign in to comment.