Fix user_score example.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3b24ce8d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3b24ce8d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3b24ce8d Branch: refs/heads/tez-runner Commit: 3b24ce8d649c44fb4fa867b9706014852eeb41da Parents: 92013ec Author: Valentyn Tymofieiev <valen...@google.com> Authored: Thu Nov 16 10:41:02 2017 -0800 Committer: Valentyn Tymofieiev <valen...@google.com> Committed: Thu Nov 16 10:41:02 2017 -0800 ---------------------------------------------------------------------- sdks/python/apache_beam/examples/complete/game/user_score.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/3b24ce8d/sdks/python/apache_beam/examples/complete/game/user_score.py ---------------------------------------------------------------------- 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 6508960..5b13eec 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)
