diff --git a/pkg/sources/gcs/gcs.go b/pkg/sources/gcs/gcs.go index 6658c5288af8..9f6f0103c4cd 100644 --- a/pkg/sources/gcs/gcs.go +++ b/pkg/sources/gcs/gcs.go @@ -265,7 +265,7 @@ func (s *Source) Chunks(ctx context.Context, chunksChan chan *sources.Chunk) err continue } - if persistableCache.Exists(o.name) { + if persistableCache.Exists(o.md5) { ctx.Logger().V(5).Info("skipping object, object already processed", "name", o.name) continue }