From 3b24ce8d649c44fb4fa867b9706014852eeb41da Mon Sep 17 00:00:00 2001 From: Valentyn Tymofieiev Date: Thu, 16 Nov 2017 10:41:02 -0800 Subject: [PATCH] Fix user_score example. --- sdks/python/apache_beam/examples/complete/game/user_score.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/examples/complete/game/user_score.py b/sdks/python/apache_beam/examples/complete/game/user_score.py index 6508960adadb..5b13eeca7a3f 100644 --- a/sdks/python/apache_beam/examples/complete/game/user_score.py +++ b/sdks/python/apache_beam/examples/complete/game/user_score.py @@ -145,7 +145,7 @@ def run(argv=None): # workflow rely on global context (e.g., a module imported at module level). options.view_as(SetupOptions).save_main_session = True - with beam.Pipeline(argv=pipeline_args) as p: + with beam.Pipeline(options=options) as p: def format_user_score_sums(user_score): (user, score) = user_score return 'user: %s, total_score: %s' % (user, score)