fix: skip empty segment ids for cdp_member_segment_aggs sinks

[epipav]

No description provided.

[cursor]

PR Summary

Medium Risk
Changes what aggregate rows reach Kafka for member/org segment sinks; correct for bad data but could hide edge cases if empty ids were relied on downstream.

Overview
Filters out empty parentId / grandparentId on CDP member segment aggregate pipes (daily “changed” sinks and bucket backfillers) so parent/grandparent rollups and segment selection no longer emit rows keyed by blank segment ids to memberSegmentsAgg_sink.

The same non-empty hierarchy id checks are added on organization bucket backfill parent/grandparent nodes (s.parentId <> '', s.grandparentId <> ''), and leaf org backfill now always applies organizationId <> '' instead of only when bucket_id is set. Optional bucket_id filtering is unchanged but moved to AND clauses on a always-present WHERE, so base exclusions still run when bucketing is omitted.

^{Reviewed by Cursor Bugbot for commit 6ee609a. Bugbot is set up for automated code reviews on this repo. Configure here.}

[CLAassistant]

Thank you for your submission! We really appreciate it. Like many open source projects, we ask that you sign our Contributor License Agreement before we can accept your contribution.
_{You have signed the CLA already but the status is still pending? Let us recheck it.}

[github-actions]

⚠️ Jira Issue Key Missing

Your PR title doesn't contain a Jira issue key. Consider adding it for better traceability.

Example:

• feat: add user authentication (CM-123)
• feat: add user authentication (IN-123)

Projects:

• CM: Community Data Platform
• IN: Insights

Please add a Jira issue key to your PR title.

[Copilot]

Pull request overview

Prevents empty hierarchy segment IDs from reaching member and organization aggregate sinks.

Changes:

• Filters empty parent and grandparent segment IDs.
• Applies filters to backfill and daily changed-aggregate sinks.
• PR title still needs the CI-required (CM-XXX) JIRA key.

Reviewed changes

Copilot reviewed 5 out of 5 changed files in this pull request and generated no comments.

Show a summary per file

File	Description
cdp_organization_aggregates_bucket_backfiller_sink.pipe	Filters invalid organization and hierarchy IDs.
cdp_member_aggregates_parent_segments_bucket_backfiller_sink.pipe	Excludes empty parent IDs.
cdp_member_aggregates_grandparent_segments_bucket_backfiller_sink.pipe	Excludes empty grandparent IDs.
cdp_member_aggregates_changed_parent_segments_sink.pipe	Filters empty parent IDs from daily exports.
cdp_member_aggregates_changed_grandparent_segments_sink.pipe	Filters empty grandparent IDs from daily exports.

---

💡 Add a code-review agent skill or configure MCP servers for context-aware, tailored reviews. Learn more in the docs.

[Copilot]

Pull request overview

Copilot reviewed 5 out of 5 changed files in this pull request and generated no new comments.