Skip to content

Commit 38cacc5

Browse files
sidneixllora
authored andcommitted
Forgot to release the semaphore, oops.
1 parent f72b546 commit 38cacc5

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

bql/planner/planner.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -511,6 +511,7 @@ func (p *queryPlan) specifyClauseWithTable(ctx context.Context, cls *semantic.Gr
511511
}
512512
r := tmpRow
513513
grp.Go(func() error {
514+
defer sem.Release(1)
514515
var tmpCls = *cls
515516
// The table manipulations are now thread safe.
516517
return p.addSpecifiedData(gCtx, r, &tmpCls, lo)
@@ -564,6 +565,7 @@ func (p *queryPlan) filterOnExistence(ctx context.Context, cls *semantic.GraphCl
564565
r := tmp
565566
cls := ocls
566567
grp.Go(func() error {
568+
defer sem.Release(1)
567569
sbj, prd, obj := cls.S, cls.P, cls.O
568570
// Attempt to rebind the subject.
569571
if sbj == nil && p.tbl.HasBinding(cls.SBinding) {

0 commit comments

Comments
 (0)