src.pipeline.writer 

1def write_parquet(df, path):
2    df.write.mode("overwrite").parquet(path)
def write_parquet(df, path): 
2def write_parquet(df, path):
3    df.write.mode("overwrite").parquet(path)