diff --git a/etl/month_end_automation_wave_2_no_8.py b/etl/month_end_automation_wave_2_no_8.py
index 3e51c9f..f7e28f7 100644
--- a/etl/month_end_automation_wave_2_no_8.py
+++ b/etl/month_end_automation_wave_2_no_8.py
@@ -98,7 +98,7 @@ def get_df(df, column_name, success_critera, job_name=None):
 
 
 # RA
-ra = get_df(df, "ra", ["completed rdsap 9.9", "complete rdsap 10"], "RA")
+ra = get_df(df, "ra status", ["completed rdsap 9.9", "complete rdsap 10"], "RA")
 filtered_dfs.append(ra)
 
 
@@ -184,13 +184,13 @@ full_lodgement = get_df(df, "full lodgement invoice status".lower(), ["to be inv
 filtered_dfs.append(full_lodgement)
 
 # POST EPC
-post_epc = get_df(df, "post epc status", ["uploaded"], "POST EPC")
+post_epc = get_df(df, "sap10 post epc status", ["uploaded"], "POST EPC")
 filtered_dfs.append(post_epc)
 
 
 # POST EPR
 post_epr = df[
-    df["post epc status"].str.lower().isin(["post epr completed"])
+    df["sap10 post epc status"].str.lower().isin(["post epr completed"])
 ].copy()
 post_epr["job_type"] = "POST epr"
 post_epr["evidence_record"] = None
@@ -198,7 +198,7 @@ post_epr["invoice_record"] = None
 filtered_dfs.append(post_epr)
 
 # Post ATT
-post_att = get_df(df, "post att", ["post att uploaded"], "POST ATT")
+post_att = get_df(df, "post att status", ["post att uploaded"], "POST ATT")
 filtered_dfs.append(post_att)