This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/airflow.git.
from cbd6daf All kubernetes tests use the same host python version (#12374)
add cfa4ecf Add DataflowJobStatusSensor and support non-blocking
execution of jobs (#11726)
No new revisions were added by this update.
Summary of changes:
.../google/cloud/example_dags/example_dataflow.py | 34 ++++
airflow/providers/google/cloud/hooks/dataflow.py | 80 +++++++--
.../providers/google/cloud/operators/dataflow.py | 155 +++++++++++++++-
...oud_storage_transfer_service.py => dataflow.py} | 94 +++++-----
.../providers/google/cloud/hooks/test_dataflow.py | 199 +++++++++++++--------
.../google/cloud/operators/test_dataflow_system.py | 4 +
.../google/cloud/operators/test_mlengine_utils.py | 1 +
.../google/cloud/sensors/test_dataflow.py | 100 +++++++++++
8 files changed, 536 insertions(+), 131 deletions(-)
copy airflow/providers/google/cloud/sensors/{cloud_storage_transfer_service.py
=> dataflow.py} (50%)
create mode 100644 tests/providers/google/cloud/sensors/test_dataflow.py
