feat(elt-pipelines): Port statusdisplay to elt-pipelines

elt-pipelines/facility_ops/transform/models/staging/accelerator/_accelerator__sources.yml

@@ -10,3 +10,8 @@ sources:
       - name: LogBookChapter
       - name: Logbooks
       - name: MoreEntryColumns
+  - name: accelerator_statusdisplay
+    database: facility_ops_landing
+    tables:
+      - name: cycles__phases
+      - name: cycles

elt-pipelines/facility_ops/transform/models/staging/accelerator/base/base_statusdisplay__cycles.sql

@@ -0,0 +1,18 @@
+with source as (
+
+    select * from {{ source('accelerator_statusdisplay', 'cycles') }}
+
+),
+
+renamed as (
+
+    select
+
+        _dlt_id as dlt_id,
+        label as name
+
+    from source
+
+)
+
+select * from renamed

elt-pipelines/facility_ops/transform/models/staging/accelerator/base/base_statusdisplay__cycles.yml

@@ -0,0 +1,11 @@
+models:
+  - name: base_statusdisplay__cycles
+    description: >
+      Each row contains the cycle id & label along with a primary key referenced
+      in the secondary base_statusdisplay__cycles__phases table where
+      information describing a particular phase of a cycle is stored.
+    columns:
+      - name: dlt_id
+        description: Primary key - unique identifier for the cycle from the source system
+      - name: name
+        description: The cycle label/name

elt-pipelines/facility_ops/transform/models/staging/accelerator/base/base_statusdisplay__cycles__phases.sql

@@ -0,0 +1,22 @@
+--  See base_statusdisplay__cycles.sql for a description of why this table exists.
+
+with source as (
+
+    select * from {{ source('accelerator_statusdisplay', 'cycles__phases') }}
+
+),
+
+renamed as (
+
+    select
+        type as phase,
+        target,
+        start as started_at,
+        {{ adapter.quote("end") }} as ended_at,
+        _dlt_parent_id as dlt_cycles_id
+
+    from source
+
+)
+
+select * from renamed

elt-pipelines/facility_ops/transform/models/staging/accelerator/base/base_statusdisplay__cycles__phases.yml

@@ -0,0 +1,16 @@
+models:
+  - name: base_statusdisplay__cycles__phases
+    description: >
+      Each row in the cycles__phases table corrseponds to a section of time
+      within a given cycle.
+    columns:
+      - name: phase
+        description: The name of the phase within the cycle
+      - name: target
+        description: The target station number that was running during this phase
+      - name: started_at
+        description: Timestamp when the phase started
+      - name: ended_at
+        description: Timestamp when the phase ended
+      - name: dlt_cycles_id
+        description: Foreign key referencing base_statusdisplay__cycles (dlt_id)

elt-pipelines/facility_ops/transform/models/staging/accelerator/stg_statusdisplay__cycles.sql

@@ -0,0 +1,35 @@
+-- Simple join to denormalize the cycles and cycles__phases tables
+-- that are not much use as separated table.
+
+{# Denormalize cycles & cycles__phases to include the cycle label for each phase #}
+
+with
+
+base_cycles as (
+
+  select * from {{ ref('base_statusdisplay__cycles') }}
+
+),
+
+base_cycles__phases as (
+
+  select * from {{ ref('base_statusdisplay__cycles__phases') }}
+
+),
+
+join_cycle_labels_and_phases as (
+
+  select
+
+    {{ adapter.quote('name') }},
+    started_at,
+    ended_at,
+    phase,
+    {{ adapter.quote('target') }}
+
+  from base_cycles
+  join base_cycles__phases on base_cycles.dlt_id = base_cycles__phases.dlt_cycles_id
+
+)
+
+select * from join_cycle_labels_and_phases

elt-pipelines/facility_ops/transform/models/staging/accelerator/stg_statusdisplay__cycles.yml

@@ -0,0 +1,25 @@
+models:
+  - name: stg_statusdisplay__cycles
+    description: >
+      Each record defines a phase of a cycle, including which target was
+      running. Multiple records exist for a given period of time if more than
+      one target station was running.
+
+unit_tests:
+  - name: test_stg_statusdisplay__cycles
+    model: stg_statusdisplay__cycles
+    given:
+      - input: ref('base_statusdisplay__cycles')
+        format: sql
+        fixture: base_statusdisplay__cycles
+      - input: ref('base_statusdisplay__cycles__phases')
+        format: sql
+        fixture: base_statusdisplay__cycles__phases
+    expect:
+      rows:
+        - {
+            name: "2024/2",
+            started_at: "2024-07-09 07:30:00 UTC",
+            ended_at: "2024-07-24 07:30:00 UTC",
+            target: 1,
+          }

warehouses/facility_ops/transform/models/staging/accelerator/stg_statusdisplay__cycles.sql

@@ -1,7 +1,7 @@
 -- Simple join to denormalize the cycles and cycles__phases tables
 -- that are not much use as separated table.
 
-{# Denormalize cycles & cycles__phases to include the cyce label for each phase #}
+{# Denormalize cycles & cycles__phases to include the cycle label for each phase #}
 
 with