feat: Add person distinct ID overrides squash job (as dagster job) (#…

…27710)
PostHog · Jan 22, 2025 · db3e85d · db3e85d
1 parent 7f49417
commit db3e85d
Show file tree

Hide file tree

Showing 12 changed files with 646 additions and 43 deletions.
diff --git a/dags/definitions.py b/dags/definitions.py
@@ -1,9 +1,14 @@
 from dagster import Definitions, load_assets_from_modules
 
 from . import ch_examples, deletes, orm_examples
+from .person_overrides import ClickhouseClusterResource, squash_person_overrides
 
 all_assets = load_assets_from_modules([ch_examples, deletes, orm_examples])
 
 defs = Definitions(
     assets=all_assets,
+    jobs=[squash_person_overrides],
+    resources={
+        "cluster": ClickhouseClusterResource.configure_at_launch(),
+    },
 )