aggtrigger nil checks

alpacahq · Jun 19, 2018 · 203dba5 · 203dba5
1 parent 3be1354
commit 203dba5
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/contrib/ondiskagg/aggtrigger/aggtrigger.go b/contrib/ondiskagg/aggtrigger/aggtrigger.go
@@ -145,14 +145,17 @@ func (s *OnDiskAggTrigger) Fire(keyPath string, records []trigger.Record) {
 
 Query:
 	csm, err := s.query(tbk, window, head, tail)
-	if err != nil {
+	if err != nil || csm == nil {
 		glog.Errorf("query error for %v (%v)", tbk.String(), err)
 		return
 	}
 
 	cs := (*csm)[*tbk]
 
-	s.write(tbk, cs, tail, head, elements)
+	if cs != nil {
+		s.write(tbk, cs, tail, head, elements)
+	}
+
 	return
 }