Merge branch 'feat/sufficiency-pipeline' into feat/sufficiency-sensor

liiatools_pipeline/jobs/sufficiency_903.py

@@ -1,7 +1,14 @@
 from dagster import job
-from liiatools_pipeline.ops.sufficiency903 import ons_area
+from liiatools_pipeline.ops.sufficiency903 import dim_tables, ons_area, looked_after_child, ofsted_provider, postcode, episode, ofsted_inspection
 
 
-@job
+@job()
 def ssda903_sufficiency():
+    dim_tables()
     ons_area()
+    looked_after_child()
+    ofsted_provider()
+    postcode()
+    episode()
+    ofsted_inspection()
+

liiatools_pipeline/ops/sufficiency903.py

@@ -1,16 +1,51 @@
 from sufficiency_data_transform.all_dim_and_fact import (
+    create_dim_tables,
     create_dimONSArea,
     create_dimLookedAfterChild,
     create_dimOfstedProvider,
     create_dimPostcode,
     create_factEpisode,
     create_factOfstedInspection,
-    create_dim_tables,
 )
 
 from dagster import op
 
 
+@op
+def dim_tables():
+    create_dim_tables()
+
 @op
 def ons_area():
     create_dimONSArea()
+
+
+@op
+def looked_after_child():
+    create_dimONSArea()
+    create_dimLookedAfterChild()
+
+@op
+def ofsted_provider():
+    create_dimONSArea()
+    create_dimOfstedProvider()
+
+@op
+def postcode():
+    create_dimPostcode()
+
+@op
+def episode():
+    create_dim_tables()
+    create_dimONSArea()
+    create_dimLookedAfterChild()
+    create_dimPostcode()
+    create_dimOfstedProvider()
+    create_factEpisode()
+
+@op
+def ofsted_inspection():
+    create_dim_tables()
+    create_dimOfstedProvider()
+    create_factOfstedInspection()
+