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 4637c9ed5c Avoid re-fetching DAG run in TriggerDagRunOperator (#27635)
add 911d90d669 Migrate Dataflow system tests (#27375)
No new revisions were added by this update.
Summary of changes:
.../operators.rst | 2 +-
.../operators/cloud/dataflow.rst | 24 +--
.../providers/google/cloud/dataflow}/__init__.py | 0
.../cloud/dataflow/example_dataflow_native_java.py | 116 ++++++++++++
.../example_dataflow_native_python.py} | 96 +++++-----
.../example_dataflow_native_python_async.py | 199 +++++++++++++++++++++
.../example_dataflow_template.py} | 69 ++++---
.../google/cloud/dataflow/resources}/__init__.py | 0
.../google/cloud/dataflow/resources/text.txt | 5 +
.../dataflow/resources/wordcount_debugging.txt | 168 +++++++++++++++++
10 files changed, 586 insertions(+), 93 deletions(-)
copy {airflow/api_connexion =>
tests/system/providers/google/cloud/dataflow}/__init__.py (100%)
create mode 100644
tests/system/providers/google/cloud/dataflow/example_dataflow_native_java.py
copy tests/system/providers/google/cloud/{gcs/example_gdrive_to_gcs.py =>
dataflow/example_dataflow_native_python.py} (52%)
create mode 100644
tests/system/providers/google/cloud/dataflow/example_dataflow_native_python_async.py
copy tests/system/providers/google/cloud/{gcs/example_gcs_transform.py =>
dataflow/example_dataflow_template.py} (56%)
copy {airflow/api_connexion =>
tests/system/providers/google/cloud/dataflow/resources}/__init__.py (100%)
create mode 100644
tests/system/providers/google/cloud/dataflow/resources/text.txt
create mode 100644
tests/system/providers/google/cloud/dataflow/resources/wordcount_debugging.txt
