Bug: missing ACTION_TYPE column

stewartbryson · Aug 9, 2023 · 6818ae5 · 6818ae5
1 parent 66aeaba
commit 6818ae5
Show file tree

Hide file tree

Showing 7 changed files with 8 additions and 7 deletions.
diff --git a/models/bronze/brokerage/sources.yml b/models/bronze/brokerage/sources.yml
@@ -2,7 +2,7 @@ version: 2
 
 sources:
   - name: brokerage
-    database: tpc_di
+    database: tpcdi
     schema: digen
     loader: snowpark
 

diff --git a/models/bronze/crm/sources.yml b/models/bronze/crm/sources.yml
@@ -2,7 +2,7 @@ version: 2
 
 sources:
   - name: crm
-    database: tpc_di
+    database: tpcdi
     schema: digen
     loader: snowpark
 

diff --git a/models/bronze/finwire/sources.yml b/models/bronze/finwire/sources.yml
@@ -2,7 +2,7 @@ version: 2
 
 sources:
   - name: finwire
-    database: tpc_di
+    database: tpcdi
     schema: digen
     loader: snowpark
 

diff --git a/models/bronze/hr/sources.yml b/models/bronze/hr/sources.yml
@@ -2,7 +2,7 @@ version: 2
 
 sources:
   - name: hr
-    database: tpc_di
+    database: tpcdi
     schema: digen
     loader: snowpark
 

diff --git a/models/bronze/reference/sources.yml b/models/bronze/reference/sources.yml
@@ -2,7 +2,7 @@ version: 2
 
 sources:
   - name: reference
-    database: tpc_di
+    database: tpcdi
     schema: digen
     loader: snowpark
 

diff --git a/models/bronze/syndicated/sources.yml b/models/bronze/syndicated/sources.yml
@@ -2,7 +2,7 @@ version: 2
 
 sources:
   - name: syndicated
-    database: tpc_di
+    database: tpcdi
     schema: digen
     loader: snowpark
 

diff --git a/tpcdi.py b/tpcdi.py
@@ -278,10 +278,11 @@ def get_phone_number(
                 xmlget(col('customer'), lit('Account'), 0).alias('account'),
                 get(col('$1'), lit('@ActionTS')).cast('STRING').alias('action_ts'),
                 get_xml_attribute('customer','C_TIER','STRING'),
+                get_xml_attribute('$1','ActionType','STRING'),
             )
             .select(
                 to_timestamp(col('action_ts'), lit('yyyy-mm-ddThh:mi:ss')).alias('action_ts'),
-                get_xml_attribute('$1','ActionType','STRING'),
+                col('ActionType').alias('ACTION_TYPE'),
                 get_xml_attribute('customer','C_ID','NUMBER'),
                 get_xml_attribute('customer','C_TAX_ID','STRING'),
                 get_xml_attribute('customer','C_GNDR','STRING'),