From 3c940ea8901ae6118e66cc4df423b8ff53699eb4 Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Wed, 26 Jul 2023 18:45:15 -0700 Subject: [PATCH] some formatting tweaks to make errors easier to grok --- .../eth/p2p/discoveryv5/providers/maintenance.nim | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/codexdht/private/eth/p2p/discoveryv5/providers/maintenance.nim b/codexdht/private/eth/p2p/discoveryv5/providers/maintenance.nim index 92ca75d..c4e6b79 100644 --- a/codexdht/private/eth/p2p/discoveryv5/providers/maintenance.nim +++ b/codexdht/private/eth/p2p/discoveryv5/providers/maintenance.nim @@ -69,8 +69,9 @@ proc cleanupExpired*( trace "Cleaned up expired records", size = keys.len proc cleanupOrphaned*( - store: Datastore, - batchSize = ExpiredCleanupBatch) {.async.} = + store: Datastore, + batchSize = ExpiredCleanupBatch +) {.async.} = trace "Cleaning up orphaned records" let @@ -109,10 +110,11 @@ proc cleanupOrphaned*( continue let - res = (await allFinished(toSeq(cidIter))) - .filterIt( it.completed ) - .mapIt( it.read.get ) - .filterIt( it.key.isSome ).len + queries = toSeq(cidIter) + cids = await allFinished(queries) + res = cids.filterIt( it.completed ) + .mapIt( it.read.get ) + .filterIt( it.key.isSome ).len if not isNil(cidIter): trace "Disposing cid iter"