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'
