Skip to content

Commit

Permalink
BED-5407: fix testing comment
Browse files Browse the repository at this point in the history
  • Loading branch information
wes-mil committed Feb 5, 2025
1 parent b76ce4f commit 3af30db
Showing 1 changed file with 7 additions and 19 deletions.
26 changes: 7 additions & 19 deletions packages/go/dawgs/traversal/id.go
Original file line number Diff line number Diff line change
Expand Up @@ -88,25 +88,13 @@ func (s IDTraversal) BreadthFirst(ctx context.Context, plan IDPlan) error {
return nil
} else if tx.GraphQueryMemoryLimit() > 0 && pathTree.SizeOf() > tx.GraphQueryMemoryLimit() {
return fmt.Errorf("%w - Limit: %.2f MB - Memory In-Use: %.2f MB", ops.ErrGraphQueryMemoryLimit, tx.GraphQueryMemoryLimit().Mebibytes(), pathTree.SizeOf().Mebibytes())
//} else if descendingSegments, err := plan.Delegate(traversalCtx, tx, nextDescent); err != nil {
// return err
//} else if len(descendingSegments) > 0 {
// for _, descendingSegment := range descendingSegments {
// // Add to the descent count before submitting to the channel
// descentCount.Add(1)
// channels.Submit(traversalCtx, segmentWriterC, descendingSegment)
// }
//}
} else {
// Traverse the descending relationships of the current segment
if descendingSegments, err := plan.Delegate(traversalCtx, tx, nextDescent); err != nil {
return err
} else {
for _, descendingSegment := range descendingSegments {
// Add to the descent count before submitting to the channel
descentCount.Add(1)
channels.Submit(traversalCtx, segmentWriterC, descendingSegment)
}
} else if descendingSegments, err := plan.Delegate(traversalCtx, tx, nextDescent); err != nil {
return err
} else if len(descendingSegments) > 0 {
for _, descendingSegment := range descendingSegments {
// Add to the descent count before submitting to the channel
descentCount.Add(1)
channels.Submit(traversalCtx, segmentWriterC, descendingSegment)
}
}

Expand Down

0 comments on commit 3af30db

Please sign in to comment.