Merge pull request #475 from kuba--/fix-iface-conv

Make a safe cast
This commit is contained in:
Kuba Podgórski 2020-06-25 15:36:53 +02:00 • committed by GitHub
commit 0bdb420b4c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -3125,11 +3125,19 @@ func (e *executor) executeSetRow(ctx context.Context, indexName string, c *pql.C
// Merge returned results at coordinating node.
reduceFn := func(ctx context.Context, prev, v interface{}) interface{} {
val := v.(bool)
if prev == nil {
val, ok := v.(bool)
if !ok {
return errors.Errorf("executeSetRow.reduceFn: val is non-bool (%+v)", v)
}
if val {
return val
}
return val || prev.(bool)
pval, ok := prev.(bool)
if !ok {
return errors.Errorf("executeSetRow.reduceFn: prev is non-bool (%+v)", prev)
}
return pval
}
result, err := e.mapReduce(ctx, indexName, shards, c, opt, mapFn, reduceFn)