diff options
Diffstat (limited to 'internal')
| -rw-r--r-- | internal/mapr/groupset.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/internal/mapr/groupset.go b/internal/mapr/groupset.go index 6ee2811..70ad28b 100644 --- a/internal/mapr/groupset.go +++ b/internal/mapr/groupset.go @@ -68,11 +68,15 @@ func (g *GroupSet) WriteResult(query *Query) error { } // -1: Don't limit the result, include all data sets - result, _, err := g.limitedResult(query, -1, "", ",", true) + result, count, err := g.limitedResult(query, -1, "", ",", true) if err != nil { return err } + if count == 0 { + logger.Warn("Not writing outfile this time as empty result set", query.Outfile) + } + logger.Info("Writing outfile", query.Outfile) tmpOutfile := fmt.Sprintf("%s.tmp", query.Outfile) |