prahul11 2023-10-27 18:25:57 +05:30
parent 233a865f9d
commit 331551916d
1 changed files with 2 additions and 0 deletions

View File

@ -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)