You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ch...@apache.org on 2021/02/11 23:54:42 UTC

[beam] 01/01: Merge pull request #13965: [BEAM-11790] Propagate pipeline options in direct runner and in Python workers

This is an automated email from the ASF dual-hosted git repository.

chamikara pushed a commit to branch release-2.28.0
in repository https://gitbox.apache.org/repos/asf/beam.git

commit bc4f57c588b370241a364fd404c46409a4690efd
Merge: 6556393 c16c5a2
Author: Chamikara Jayalath <ch...@apache.org>
AuthorDate: Thu Feb 11 15:53:40 2021 -0800

    Merge pull request #13965: [BEAM-11790] Propagate pipeline options in direct runner and in Python workers

 .../apache_beam/examples/snippets/snippets_test.py | 31 +++++++++++-----------
 .../apache_beam/runners/direct/direct_runner.py    | 11 ++++++--
 .../portability/fn_api_runner/worker_handlers.py   |  5 +++-
 .../runners/portability/local_job_service.py       | 10 +++++--
 .../runners/portability/portable_runner.py         |  7 +++++
 .../apache_beam/runners/worker/sdk_worker_main.py  |  2 ++
 6 files changed, 46 insertions(+), 20 deletions(-)