rosetn commented on a change in pull request #11706:
URL: https://github.com/apache/beam/pull/11706#discussion_r441217968
##########
File path: website/www/site/content/en/documentation/runners/direct.md
##########
@@ -74,55 +74,65 @@ Local execution is limited by the memory available in your
local environment. It
If your pipeline uses an unbounded data source or sink, you must set the
`streaming` option to `true`.
+{:.language-py}
### Execution Mode
+{:.language-py}
Python
[FnApiRunner](https://beam.apache.org/contribute/runner-guide/#the-fn-api)
supports multi-threading and multi-processing mode.
+{:.language-py}
<strong>Setting parallelism</strong>
+{:.language-py}
Number of threads or subprocesses is defined by setting the
`direct_num_workers` option.
From 2.22.0, `direct_num_workers = 0` is supported. When `direct_num_workers`
is set to 0, it will set the number of threads/subprocess to the number of
cores of the machine where the pipelien is running.
Review comment:
Sorry, this is outside of the diff, but can you change
"pipelien"->"pipeline"
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
