def check_table_migration( team:str, table_name_snowflake:str, table_name_aws:str, primary_key:Union[str, list[str]], environnement:str, batch_size:int, thresold:float )-> None: print(f"Load Snowflake and AWS tables : {table_name_snowflake} and {table_name_aws}\n") snowflake: pd.DataFrame = get_snowflake_table(table_name_snowflake, environnement) aws: pd.DataFrame = get_aws_table(table_name_aws, team) print(f"\nChecks :") check_lengths(snowflake, aws) check_column_names(snowflake, aws) check_column_types(snowflake, aws) check_column_values_by_batch(snowflake, aws, primary_key, batch_size) print("\nEnd of migration monitoring")