Merge pull request #81 from alpacahq/fix/aggtrigger-nil-check

after-hours aggtrigger nil checks
alpacahq · Jun 19, 2018 · eb953e2 · eb953e2
2 parents 3be1354 + 203dba5
commit eb953e2
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
 }