feat: add node roles to del dag

[fuziontech]

Problem

We have Node roles now, let's use them to target where we are running certain queries in delete dag

Changes

added a few functions I'm sure greptile will see 👀

👉 Stay up-to-date with PostHog coding conventions for a smoother review.

Does this work well for both Cloud and self-hosted?

How did you test this code?

[greptile-apps]

PR Summary

This PR enhances ClickHouse cluster operations by introducing node role-based query execution in the deletion DAG system.

• Added any_host_by_role method in /posthog/clickhouse/cluster.py to execute operations on specific node types
• Modified /dags/deletes.py to target worker nodes specifically for deletion operations using map_hosts_by_role
• Potential edge case in any_host_by_role where it may raise StopIteration if no host matches the specified role
• Added role-based filtering in map_hosts_by_role with host.host_cluster_role == node_role.value.lower()
• Improved deletion workflow by ensuring operations run only on appropriate worker nodes rather than all cluster nodes

_{2 file(s) reviewed, 1 comment(s)
Edit PR Review Bot Settings | Greptile}