Skip to content

Commit

Permalink
fix testcase
Browse files Browse the repository at this point in the history
  • Loading branch information
alanpo1 committed Jul 23, 2024
1 parent bc467b5 commit cc5b1ed
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,6 @@ class TestDFUtils:
def test_save_spark_df_as_mltable(self):
"""Test the save dataframe as mltable functionality."""
spark = init_spark()
production_df = spark.createDataFrame([(1, "c"), (2, "d")], ["id", "age", "Id"])
production_df = spark.createDataFrame([(1, "c", "bob"), (2, "d", "BOB")], ["id", "age", "Id"])
save_spark_df_as_mltable(production_df, "localData")
assert os.path.exists("localData/") == True

0 comments on commit cc5b1ed

Please sign in to comment.