feat: add event filtering framework with pre-deserialization MCL optimization#17593

Merged

sgomezvillamor merged 13 commits into

claude/datahub-actions-config-plan-35owc

Jun 2, 2026

Commits on May 26, 2026

feat(actions): add first-class Filter abstraction with EventTypeFilter and pre-deserialization KafkaSource optimization
claude
committed

Commits on May 27, 2026

fix(actions): rename flag to enable_mcl_pre_deserialization_filter, fix skip_mcl_entirely bug, restrict early criteria keys
claude
committed
fix(actions): warn on conflicting early MCL criteria, distinguish entirely_rejected metric label
claude
committed
fix(actions): merge executor aspectName predicates into list, add comments to slack/teams configs
claude
committed
fix(actions): fix mypy errors in EventTypeFilter.create return type and test helper
claude
committed
fix(actions): fix EventTypeFilter null-spec bug, Pipeline per-instance stats, and integration test
claude
committed
fix(actions): give PipelineStats an __init__ to avoid class-level dict sharing
claude
committed
fix(actions): fix PipelineStats.as_string() to not serialize non-JSON nested objects
claude
committed
refactor(actions): make as_string() explicit and complete across all stats classes
claude
committed
refactor(actions): add __init__ to ActionStats, TransformerStats, FilterStats
claude
committed

Commits on May 29, 2026

Commits on Jun 2, 2026

Merge branch 'master' into claude/datahub-actions-config-plan-35owc
sgomezvillamor
authored