Skip to content

Commit

Permalink
Fix tests
Browse files Browse the repository at this point in the history
  • Loading branch information
akariv committed Sep 13, 2018
1 parent afe7b93 commit a8fba71
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions tests/test_examples.py
Original file line number Diff line number Diff line change
Expand Up @@ -234,20 +234,20 @@ def test_example_9():

f = Flow(
# Emmy award nominees and winners
load('emmy.csv', name='emmies'),
load('data/emmy.csv', name='emmies'),
filter_rows(equals=[dict(winner=1)]),
concatenate(dict(
emmy_nominee=['nominee'],
),
dict(name='emmies_filtered'),
resources='emmies'),
# Academy award nominees and winners
load('academy.csv', encoding='utf8', name='oscars'),
load('data/academy.csv', encoding='utf8', name='oscars'),
join('emmies_filtered', ['emmy_nominee'], # Source resource
'oscars', ['Name'], # Target resource
full=False # Don't add new fields, remove unmatched rows
),
filter_rows(equals=[dict(Winner='1')]),
dump_to_path('double_winners')
dump_to_path('out/double_winners')
)
_ = f.process()

0 comments on commit a8fba71

Please sign in to comment.