diff --git a/src/sentry/digests/backends/redis.py b/src/sentry/digests/backends/redis.py index 5f0c51f0ec2629..04cb6169477404 100644 --- a/src/sentry/digests/backends/redis.py +++ b/src/sentry/digests/backends/redis.py @@ -234,7 +234,17 @@ def digest( # If the record value is `None`, this means the record data was # missing (it was presumably evicted by Redis) so we don't need to # return it here. - yield [record for record in records if record.value is not None] + filtered_records = [record for record in records if record.value is not None] + if len(records) != len(filtered_records): + logger.warning( + "Filtered out missing records when fetching digest", + extra={ + "key": key, + "record_count": len(records), + "filtered_record_count": len(filtered_records), + }, + ) + yield filtered_records script( connection,