Skip to content

Commit

Permalink
engine: get rid of debug printing
Browse files Browse the repository at this point in the history
Signed-off-by: Michael Hoffmann <[email protected]>
  • Loading branch information
MichaHoffmann committed Nov 25, 2023
1 parent 41fee06 commit 2e4e526
Showing 1 changed file with 0 additions and 47 deletions.
47 changes: 0 additions & 47 deletions engine/engine.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,11 +6,9 @@ package engine
import (
"context"

"io"
"math"
"runtime"
"sort"
"strconv"
"time"

"github.com/efficientgo/core/errors"
Expand Down Expand Up @@ -521,48 +519,3 @@ func recoverEngine(logger log.Logger, expr parser.Expr, errp *error) {
*errp = errors.Wrap(err, "unexpected error")
}
}

func analyze(w io.Writer, o model.ObservableVectorOperator, indent, indentNext string) {
telemetry, next := o.Analyze()
_, _ = w.Write([]byte(indent))
_, _ = w.Write([]byte("Operator Time :"))
_, _ = w.Write([]byte(strconv.FormatInt(int64(telemetry.ExecutionTimeTaken()), 10)))
if len(next) == 0 {
_, _ = w.Write([]byte("\n"))
return
}
_, _ = w.Write([]byte(":\n"))

for i, n := range next {
if i == len(next)-1 {
analyze(w, n, indentNext+"└──", indentNext+" ")
} else {
analyze(w, n, indentNext+"└──", indentNext+" ")
}
}
}

func explain(w io.Writer, o model.VectorOperator, indent, indentNext string) {
me, next := o.Explain()
_, _ = w.Write([]byte(indent))
_, _ = w.Write([]byte(me))
if len(next) == 0 {
_, _ = w.Write([]byte("\n"))
return
}

if me == "[*CancellableOperator]" {
_, _ = w.Write([]byte(": "))
explain(w, next[0], "", indentNext)
return
}
_, _ = w.Write([]byte(":\n"))

for i, n := range next {
if i == len(next)-1 {
explain(w, n, indentNext+"└──", indentNext+" ")
} else {
explain(w, n, indentNext+"├──", indentNext+"│ ")
}
}
}

0 comments on commit 2e4e526

Please sign in to comment.