Update common_task.py
parent
1e8d5476f3
commit
eafe0220f2
|
@ -43,7 +43,7 @@ def read_s3_file(filenameInS3):
|
||||||
# # Print or process the file contents
|
# # Print or process the file contents
|
||||||
# print(file_content.decode('utf-8')) # Assumes the file is text; adjust accordingly
|
# print(file_content.decode('utf-8')) # Assumes the file is text; adjust accordingly
|
||||||
|
|
||||||
def do_the_difference(today_file, last_file, column_for_diff, fresh_output, expired_output, common_output=None, gi):
|
def do_the_difference(today_file, last_file, column_for_diff, fresh_output, expired_output, common_output, gi):
|
||||||
today_df = pd.read_csv(today_file)
|
today_df = pd.read_csv(today_file)
|
||||||
last_file_df = pd.read_csv(last_file)
|
last_file_df = pd.read_csv(last_file)
|
||||||
print(today_df.shape, last_file_df.shape)
|
print(today_df.shape, last_file_df.shape)
|
||||||
|
|
Loading…
Reference in New Issue