scriptoriumadmin/GitNexus
1
0
Fork 0
mirror of https://github.com/abhigyanpatwari/GitNexus.git synced 2026-10-11 03:38:07 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 7

refactor(lbug): rel COPY uses the captured writeConn, matching node COPY (#2264 review P3)

Browse source 
The relationship COPY passed the module-level `conn` to copyCsvWithRetry while the
node COPY uses the captured `writeConn`. Use `writeConn` for both — one captured
reference for the whole bulk load, removing the latent identity dependency. Same
object during analyze (`conn` is only reassigned at open/close under the session
lock), so the queryAndDrain `targetConn === conn` lock gate still engages.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01JBJomjoTdBV2eveDVq4JMm
This commit is contained in:
Gergo Magyar 2026-06-21 08:34:53 +00:00
parent c2275c81e6
commit 17b0b93e35
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
gitnexus/src/core/lbug/lbug-adapter.ts
View file

@ -1136,7 +1136,12 @@ export const loadGraphToLbug = async (
log(`Loading edges: ${pairIdx}/${relsByPair.size} types (${fromLabel} -> ${toLabel})`);
}
await copyCsvWithRetry(conn, copyQuery, (retryErr) => {
// Use the captured `writeConn` (not the module-level `conn`) for the rel
// COPY, matching the node COPY above — one captured reference for the whole
// bulk load (#2264 review P3). Same object during analyze (`conn` is only
// reassigned at open/close under the session lock, never mid-load), so the
// queryAndDrain `targetConn === conn` lock gate still engages.
await copyCsvWithRetry(writeConn, copyQuery, (retryErr) => {
const retryMsg = retryErr instanceof Error ? retryErr.message : String(retryErr);
warnings.push(`${fromLabel}->${toLabel} (${rows} edges): ${retryMsg.slice(0, 80)}`);
failedPairEdges += rows;