From a621c7fa807e911663aa3951edda8212e218d821 Mon Sep 17 00:00:00 2001 From: borisssmidtCET <134265736+borisssmidtCET@users.noreply.github.com> Date: Tue, 25 Jul 2023 18:04:37 +0200 Subject: [PATCH] Update filter.go to missing when using sliding windows data. (#84) --- pipeline/collection/filter.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pipeline/collection/filter.go b/pipeline/collection/filter.go index 5dbbc3a..72f4a47 100644 --- 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 } }