Update filter.go to missing when using sliding windows data. (#84)

larrabee · Jul 25, 2023 · a621c7f · a621c7f
1 parent 54a5695
commit a621c7f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pipeline/collection/filter.go b/pipeline/collection/filter.go
@@ -131,7 +131,7 @@ var FilterObjectsByMtimeAfter pipeline.StepFn = func(group *pipeline.Group, step
 	}
 	for obj := range input {
 		if ok {
-			if obj.Mtime.Unix() > cfg {
+			if obj.Mtime.Unix() >= cfg {
 				output <- obj
 			}
 		}