From fb7bd66bc2eb9457847dbd32e5ec8553ba0d12a8 Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Tue, 18 Oct 2016 15:10:02 -0500 Subject: [PATCH] added remote termination clause for clearbit --- executor.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/executor.go b/executor.go index 4e1fa40dd..85857daf6 100644 --- a/executor.go +++ b/executor.go @@ -430,6 +430,10 @@ func (e *Executor) executeClearBit(db string, c *pql.ClearBit, opt *ExecOptions) } continue } + // Do not forward call if this is already being forwarded. + if opt.Remote { + continue + } // Forward call to remote node otherwise. if res, err := e.exec(node, db, &pql.Query{Calls: pql.Calls{c}}, nil, opt); err != nil {