This is an automated email from the ASF dual-hosted git repository.
eladkal pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 90442e85775 [Edge] Edge worker supports capacity handling instead of
concurrency (#43737)
add 43adccf57b2 Fix deferrable mode of BeamRunPythonPipelineOperator
(#44386)
No new revisions were added by this update.
Summary of changes:
.../providers/apache/beam/operators/beam.py | 26 +++++-----------------
.../airflow/providers/apache/beam/triggers/beam.py | 20 +++++++++++++++++
providers/tests/apache/beam/operators/test_beam.py | 10 ++-------
providers/tests/apache/beam/triggers/test_beam.py | 15 +++++++++++++
.../dataflow/example_dataflow_native_python.py | 18 +++++++++++++--
5 files changed, 58 insertions(+), 31 deletions(-)
