This is an automated email from the ASF dual-hosted git repository. goenka pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push: new 9293a81 Removing none instead of bare return new 6463d6e Merge pull request #10724 from angoenka/uw_option 9293a81 is described below commit 9293a819e554957c61d51018d7d1b910a09ff91d Author: Ankur <angoe...@users.noreply.github.com> AuthorDate: Wed Jan 29 21:58:52 2020 -0800 Removing none instead of bare return --- sdks/python/apache_beam/runners/dataflow/internal/apiclient.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py index 6a5c46d..d3296df 100644 --- a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py +++ b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py @@ -891,7 +891,7 @@ def _use_fnapi(pipeline_options): def _use_unified_worker(pipeline_options): if not _use_fnapi(pipeline_options): - return + return False debug_options = pipeline_options.view_as(DebugOptions) use_unified_worker_flag = 'use_unified_worker'