diff --git a/common_task.py b/common_task.py index 3ce2a17..c429e47 100644 --- a/common_task.py +++ b/common_task.py @@ -63,6 +63,8 @@ def do_the_difference(today_file, last_file, column_for_diff, fresh_output, expi child_df_copy['jobId'] = 'i_' + child_df_copy['jobId'].astype(str) expired_df['jobId'] = expired_df['jobId'].astype(str) expired_df = pd.concat([expired_df, child_df_copy], ignore_index=True) + expired_df = expired_df.rename(columns={'jobId': 'Job Key'}) + expired_df.to_csv(expired_output, index=False) print(new_df.shape, expired_df.shape)