diff --git a/etl/month_end_automation_wave_2_layout.py b/etl/month_end_automation_wave_2_layout.py index 174fe0b..f93f8f3 100644 --- a/etl/month_end_automation_wave_2_layout.py +++ b/etl/month_end_automation_wave_2_layout.py @@ -120,7 +120,7 @@ v3 = df[ v3["job_type"] = "Coordination Stage 1 v3 remodel" filtered_dfs.append(v3) -# Coordination stage 2 +# Coordination stage 2 Please complete cors2 = df[ df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) ] diff --git a/etl/month_end_automation_wave_2_no_10.py b/etl/month_end_automation_wave_2_no_10.py index d779e45..29e5845 100644 --- a/etl/month_end_automation_wave_2_no_10.py +++ b/etl/month_end_automation_wave_2_no_10.py @@ -97,6 +97,13 @@ filtered_dfs.append(v1) # v3 = get_df(df, "") # # filtered_dfs.append(v3) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + # Design stage 1 design1 = get_df(df, "design upload to sharepoint", ["done"], "Design") filtered_dfs.append(design1) diff --git a/etl/month_end_automation_wave_2_no_11.py b/etl/month_end_automation_wave_2_no_11.py index 2eeb76e..da17811 100644 --- a/etl/month_end_automation_wave_2_no_11.py +++ b/etl/month_end_automation_wave_2_no_11.py @@ -97,6 +97,13 @@ filtered_dfs.append(v2) # v3 = get_df(df, "") # filtered_dfs.append(v3) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + # Design stage 1 # design1 = get_df(df, "", ["done"], "Design") # filtered_dfs.append(design1) diff --git a/etl/month_end_automation_wave_2_no_12.py b/etl/month_end_automation_wave_2_no_12.py index fbe4bf0..0de0630 100644 --- a/etl/month_end_automation_wave_2_no_12.py +++ b/etl/month_end_automation_wave_2_no_12.py @@ -97,6 +97,13 @@ filtered_dfs.append(v2) # v3 = get_df(df, "") # filtered_dfs.append(v3) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + # Design stage 1 # design1 = get_df(df, "", ["done"], "Design") # filtered_dfs.append(design1) diff --git a/etl/month_end_automation_wave_2_no_13.py b/etl/month_end_automation_wave_2_no_13.py index 30a09bf..f0bfe90 100644 --- a/etl/month_end_automation_wave_2_no_13.py +++ b/etl/month_end_automation_wave_2_no_13.py @@ -96,6 +96,13 @@ filtered_dfs.append(v2) # v3 = get_df(df, "") # filtered_dfs.append(v3) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + # Design stage 1 # design1 = get_df(df, "", ["done"], "Design") # filtered_dfs.append(design1) diff --git a/etl/month_end_automation_wave_2_no_14.py b/etl/month_end_automation_wave_2_no_14.py index 733be63..e3286ea 100644 --- a/etl/month_end_automation_wave_2_no_14.py +++ b/etl/month_end_automation_wave_2_no_14.py @@ -99,6 +99,13 @@ filtered_dfs.append(v3) v3 = get_df(df, "v3 invoice status", ["to be invoice"], "V3 Coordination") filtered_dfs.append(v3) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + # Design stage 1 design1 = get_df(df, "design invoice status", ["to invoice"], "Design") filtered_dfs.append(design1) diff --git a/etl/month_end_automation_wave_2_no_15.py b/etl/month_end_automation_wave_2_no_15.py index 9348fe4..bcdc46b 100644 --- a/etl/month_end_automation_wave_2_no_15.py +++ b/etl/month_end_automation_wave_2_no_15.py @@ -96,9 +96,17 @@ filtered_dfs.append(v1) # v3 = get_df(df, "v3 rc status", ["uploaded"], "V3 Coordination") # filtered_dfs.append(v3) + # v3 = get_df(df, "v3 invoice status", ["to be invoice"], "V3 Coordination") # filtered_dfs.append(v3) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + # Design stage 1 design1 = get_df(df, "design invoice status", ["to invoice"], "Design") filtered_dfs.append(design1) diff --git a/etl/month_end_automation_wave_2_no_16.py b/etl/month_end_automation_wave_2_no_16.py index ce43999..8b83fe9 100644 --- a/etl/month_end_automation_wave_2_no_16.py +++ b/etl/month_end_automation_wave_2_no_16.py @@ -99,6 +99,13 @@ filtered_dfs.append(v1) # v3 = get_df(df, "v3 invoice status", ["to be invoice"], "V3 Coordination") # filtered_dfs.append(v3) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + # Design stage 1 # design1 = get_df(df, "design invoice status", ["to invoice"], "Design") # filtered_dfs.append(design1) diff --git a/etl/month_end_automation_wave_2_no_3.py b/etl/month_end_automation_wave_2_no_3.py index 56b2efd..90253d5 100644 --- a/etl/month_end_automation_wave_2_no_3.py +++ b/etl/month_end_automation_wave_2_no_3.py @@ -102,6 +102,13 @@ filtered_dfs.append(_) # v3["job_type"] = "V3 Coordination" # filtered_dfs.append(v3) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + # Design stage 1 design1 = df[ df["design invoice"].str.lower().isin(["complete pending rc"]) diff --git a/etl/month_end_automation_wave_2_no_4.py b/etl/month_end_automation_wave_2_no_4.py index 4678aba..b750850 100644 --- a/etl/month_end_automation_wave_2_no_4.py +++ b/etl/month_end_automation_wave_2_no_4.py @@ -100,6 +100,13 @@ v3 = df[df["v3 rc status"].str.lower().isin(['uploaded'])].copy() v3["job_type"] = "V3 Coordination" filtered_dfs.append(_) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + # Design stage 1 design1 = df[ df["design invoice status"].str.lower().isin(["complete", "to invoice"]) diff --git a/etl/month_end_automation_wave_2_no_5.py b/etl/month_end_automation_wave_2_no_5.py index f244dc5..5ed035b 100644 --- a/etl/month_end_automation_wave_2_no_5.py +++ b/etl/month_end_automation_wave_2_no_5.py @@ -100,6 +100,13 @@ filtered_dfs.append(v1) # v3["job_type"] = "V3 Coordination" # filtered_dfs.append(_) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + # Design stage 1 design1 = df[ df["retrofit design status"].str.lower().isin(["to invoice"]) diff --git a/etl/month_end_automation_wave_2_no_6.py b/etl/month_end_automation_wave_2_no_6.py index d069018..1b149ae 100644 --- a/etl/month_end_automation_wave_2_no_6.py +++ b/etl/month_end_automation_wave_2_no_6.py @@ -102,6 +102,13 @@ filtered_dfs.append(v1) # v3["job_type"] = "V3 Coordination" # filtered_dfs.append(_) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + # Design stage 1 design1 = get_df(df, "retrofit design status", ["completed"], "Design") filtered_dfs.append(design1) diff --git a/etl/month_end_automation_wave_2_no_7.py b/etl/month_end_automation_wave_2_no_7.py index d834847..46d0a33 100644 --- a/etl/month_end_automation_wave_2_no_7.py +++ b/etl/month_end_automation_wave_2_no_7.py @@ -99,6 +99,13 @@ filtered_dfs.append(v2) # v3 = get_df(df, "") # # filtered_dfs.append(v3) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + # Design stage 1 design1 = get_df(df, "design invoice status", ["to invoice"], "Design") filtered_dfs.append(design1) diff --git a/etl/month_end_automation_wave_2_no_8.py b/etl/month_end_automation_wave_2_no_8.py index 8951e71..653c543 100644 --- a/etl/month_end_automation_wave_2_no_8.py +++ b/etl/month_end_automation_wave_2_no_8.py @@ -116,7 +116,6 @@ filtered_dfs.append(v2) # v3 = get_df(df, "") # # filtered_dfs.append(v3) -# TODO check with Kevin [Coordination stage 2, design complex and revision] # Corodination stage 2 cors2 = get_df(df, "rc stg. 2", ["to invoice"], "Coordination Stage 2") filtered_dfs.append(cors2) diff --git a/etl/month_end_automation_wave_2_no_9.py b/etl/month_end_automation_wave_2_no_9.py index f295ca6..a24b6e7 100644 --- a/etl/month_end_automation_wave_2_no_9.py +++ b/etl/month_end_automation_wave_2_no_9.py @@ -98,6 +98,13 @@ filtered_dfs.append(v1) # v3 = get_df(df, "") # # filtered_dfs.append(v3) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + # Design stage 1 # design1 = get_df(df, "rd invoiced", ["to invoice"], "Design") # filtered_dfs.append(design1) diff --git a/etl/month_end_automation_wave_3_layout.py b/etl/month_end_automation_wave_3_layout.py index 9a051e9..3b5f53f 100644 --- a/etl/month_end_automation_wave_3_layout.py +++ b/etl/month_end_automation_wave_3_layout.py @@ -111,6 +111,13 @@ v3 = get_df(df, "mtp invoicing status", ["(v3) ioe/mtp to invoice"], "V3 Coordin if v3 is not None: filtered_dfs.append(v3) +# Coordination stage 2 Please complete +# cors2 = df[ +# df["rc stg. 2"].str.lower().isin(["to invoice", "completed"]) +# ] +# cors2["joby_type"] = "Coordination Stage 2" +# filtered_dfs.append(cors2) + design1 = get_df(df, "design invoicing status", ["to invoice"], "Design") if design1 is not None: filtered_dfs.append(design1)