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 <[email protected]> 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(-)
