Skip to content

Commit

Permalink
Add testing for rename_col and lookup
Browse files Browse the repository at this point in the history
  • Loading branch information
FavioVazquez committed Sep 21, 2017
1 parent 9b6fae8 commit 3181587
Showing 1 changed file with 22 additions and 0 deletions.
22 changes: 22 additions & 0 deletions tests/tests.py
Original file line number Diff line number Diff line change
Expand Up @@ -134,3 +134,25 @@ def test_remove_special_chars_regex(spark_session):
logger.exception('Could not run remove_special_chars_regex().')
sys.exit(1)


def test_rename_col(spark_session):
try:
transformer = op.DataFrameTransformer(create_df(spark_session))
names = [('city', 'villes')]
transformer.rename_col(names)
assert_spark_df(transformer.get_data_frame)
except RuntimeError:
logger.exception('Could not run rename_col().')
sys.exit(1)


def test_lookup(spark_session):
try:
transformer = op.DataFrameTransformer(create_df(spark_session))
transformer.lookup('city', ['Caracas', 'Ccs'], 'Caracas')
assert_spark_df(transformer.get_data_frame)
except RuntimeError:
logger.exception('Could not run lookup().')
sys.exit(1)


0 comments on commit 3181587

Please sign in to comment.