Skip to content

Commit

Permalink
Move debug log about pushing result to where the result is pushed
Browse files Browse the repository at this point in the history
  • Loading branch information
JohnStarich committed Aug 20, 2024
1 parent c2404b2 commit e005dbc
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions execute.go
Original file line number Diff line number Diff line change
Expand Up @@ -162,6 +162,7 @@ func executeStep(
queryResult, dependentSteps, queryErr := executeOneStep(ctx, plan, step, insertionPoint, resultLock, queryVariables)
// before publishing the current result, tell the wait-group about the dependent steps to wait for
stepWg.Add(len(dependentSteps))
ctx.logger.Debug("Pushing Result. Insertion point: ", insertionPoint, ". Value: ", queryResult)
// send the result to be stitched in with our accumulator
resultCh <- &queryExecutionResult{
InsertionPoint: insertionPoint,
Expand Down Expand Up @@ -309,9 +310,6 @@ func executeOneStep(
}
}
}

ctx.logger.Debug("Pushing Result. Insertion point: ", insertionPoint, ". Value: ", queryResult)
// send the result to be stitched in with our accumulator
return queryResult, dependentSteps, nil
}

Expand Down

0 comments on commit e005dbc

Please sign in to comment.