This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 36766d1f62c Remove unnecessary noise from CI breeze's output (#49952)
add 09ba6a34db9 Add new DataflowJobStateCompleteTrigger (#47993)
No new revisions were added by this update.
Summary of changes:
.../airflow/providers/apache/beam/hooks/beam.py | 11 +-
.../providers/apache/beam/operators/beam.py | 108 +++++++++++-----
.../airflow/providers/apache/beam/triggers/beam.py | 64 ++++-----
.../tests/unit/apache/beam/triggers/test_beam.py | 27 ++--
providers/google/docs/operators/cloud/dataflow.rst | 18 +++
.../providers/google/cloud/hooks/dataflow.py | 72 ++++++++++-
.../providers/google/cloud/triggers/dataflow.py | 122 +++++++++++++++++
.../dataflow/example_dataflow_java_streaming.py | 42 +++++-
.../dataflow/example_dataflow_streaming_python.py | 45 ++++++-
.../tests/unit/google/cloud/hooks/test_dataflow.py | 10 +-
.../unit/google/cloud/triggers/test_dataflow.py | 144 +++++++++++++++++++++
11 files changed, 574 insertions(+), 89 deletions(-)
