[beam] branch master updated (a74374d -> 53e025b)

[ro...@apache.org]

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

robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from a74374d  [BEAM-10036] More flexible dataframes partitioning. (#11766)
     add a7866b5  [BEAM-10116] Allow unknown non-merging windowing strategies in ULR.
     add 6eefa9c  Never trigger for Python.
     add edbe4ce  Add a hack to ensure the Never() trigger fires on window closing in batch mode.
     add ae36a5d  [BEAM-10118] Unconditionally use safe coders for data channels in FnAPI runner.
     add 3ac5dd7  Use trivial Flatten rather than identity DoFn for transcoding.
     add a07fac8  Fix GetState API to handle timestamps field.
     add 78ed270  Typing fix.
     add 53e025b  Various fixes to allow Java PAssert to run on Python (#11835)

No new revisions were added by this update.

Summary of changes:
 .../runners/portability/abstract_job_service.py    |  5 +-
 .../runners/portability/fn_api_runner/execution.py | 57 +++++++++++++++++++++-
 .../portability/fn_api_runner/translations.py      | 55 +++++++++++++--------
 sdks/python/apache_beam/transforms/core.py         |  2 +-
 sdks/python/apache_beam/transforms/trigger.py      | 52 +++++++++++++++++++-
 sdks/python/apache_beam/transforms/trigger_test.py | 31 ++++++++++++
 6 files changed, 174 insertions(+), 28 deletions(-)