Initial work from pairing session

SocialFinanceDigitalLabs · Apr 10, 2024 · d115dc4 · d115dc4
1 parent cbaad3c
commit d115dc4
Show file tree

Hide file tree

Showing 4 changed files with 22 additions and 9 deletions.
diff --git a/liiatools_pipeline/jobs/sufficiency_903.py b/liiatools_pipeline/jobs/sufficiency_903.py
@@ -1,9 +1,7 @@
-from sufficiency_data_transform.all_dim_and_fact import create_sufficiency_data
 from dagster import job
-from liiatools_pipeline.ops import ssda903
+from liiatools_pipeline.ops.sufficiency903 import ons_area
 
 
 @job
 def ssda903_sufficiency():
-    print("Hi")
-    create_sufficiency_data()
+    ons_area()
diff --git a/liiatools_pipeline/ops/sufficiency903.py b/liiatools_pipeline/ops/sufficiency903.py
@@ -0,0 +1,15 @@
+from sufficiency_data_transform.all_dim_and_fact import (
+    create_dimONSArea,
+    create_dimLookedAfterChild,
+    create_dimOfstedProvider,
+    create_dimPostcode,
+    create_factEpisode,
+    create_factOfstedInspection,
+    create_dim_tables,
+)
+
+from dagster import op
+
+@op
+def ons_area():
+    create_dimONSArea()
diff --git a/poetry.lock b/poetry.lock
diff --git a/pyproject.toml b/pyproject.toml
@@ -40,7 +40,7 @@ dagster = "^1.6.11"
 dagster-webserver = "^1.6.11"
 dagster-docker = "^0.22.11"
 dagster-postgres = "^0.22.11"
-sufficiency-data-transform = "0.1.2"
+sufficiency-data-transform = "0.1.3"
 alembic = "^1.13.1"
 python-dateutil = "^2.9.0.post0"