You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by cc...@apache.org on 2019/05/28 23:02:42 UTC
[beam] 01/01: Update thread count default comment in
sdk_worker_main.py
This is an automated email from the ASF dual-hosted git repository.
ccy pushed a commit to branch charlesccychen-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 9f4ce1c6fc2fb195e218783a6e9ce6104ddb4d1e
Author: Charles Chen <ch...@users.noreply.github.com>
AuthorDate: Tue May 28 16:02:30 2019 -0700
Update thread count default comment in sdk_worker_main.py
---
sdks/python/apache_beam/runners/worker/sdk_worker_main.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/runners/worker/sdk_worker_main.py b/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
index 3748bd4..31585de 100644
--- a/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
+++ b/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
@@ -181,7 +181,7 @@ def _get_worker_count(pipeline_options):
future releases.
Returns:
- an int containing the worker_threads to use. Default is 1
+ an int containing the worker_threads to use. Default is 12
"""
experiments = pipeline_options.view_as(DebugOptions).experiments