diff --git a/models/bronze/brokerage/sources.yml b/models/bronze/brokerage/sources.yml
index 1d6ccbb..51c2954 100644
--- 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
index 2b1f17b..ee1c1fe 100644
--- 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
index 012db6c..439f656 100644
--- 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
index 189adac..64e641d 100644
--- 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
index 776b69a..e42010f 100644
--- 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
index 0e38b96..56aac34 100644
--- 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
index 581a640..3613746 100644
--- 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'),