aggtrigger length check

alpacahq · Jun 26, 2018 · 24c9eec · 24c9eec
1 parent 006ead1
commit 24c9eec
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/contrib/ondiskagg/aggtrigger/aggtrigger.go b/contrib/ondiskagg/aggtrigger/aggtrigger.go
@@ -226,6 +226,10 @@ func (s *OnDiskAggTrigger) writeAggregates(
 		return err
 	}
 
+	if len(slc.GetEpoch()) == 0 {
+		return nil
+	}
+
 	// decide whether to apply market-hour filter
 	applyingFilter := false
 	if s.filter == "nasdaq" && window.Duration() >= utils.Day {