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 14805cc Clean-up JS code in UI templates (#14019)
add 1872d87 Add Apache Beam operators (#12814)
No new revisions were added by this update.
Summary of changes:
CONTRIBUTING.rst | 3 +-
.../apache/beam/BACKPORT_PROVIDER_README.md | 99 +++
.../{zendesk => apache/beam}/CHANGELOG.rst | 0
airflow/providers/apache/beam/README.md | 97 +++
.../providers/apache/beam}/__init__.py | 0
.../apache/beam/example_dags}/__init__.py | 0
.../apache/beam/example_dags/example_beam.py | 315 +++++++++
.../providers/apache/beam/hooks}/__init__.py | 0
airflow/providers/apache/beam/hooks/beam.py | 289 ++++++++
.../providers/apache/beam/operators}/__init__.py | 0
airflow/providers/apache/beam/operators/beam.py | 446 ++++++++++++
.../{discord => apache/beam}/provider.yaml | 29 +-
airflow/providers/dependencies.json | 4 +
airflow/providers/google/cloud/hooks/dataflow.py | 330 ++++-----
.../providers/google/cloud/operators/dataflow.py | 331 +++++++--
.../copy_provider_package_sources.py | 62 ++
dev/provider_packages/prepare_provider_packages.py | 4 +-
.../index.rst | 11 +-
.../operators.rst | 116 ++++
docs/apache-airflow/extra-packages-ref.rst | 2 +-
docs/spelling_wordlist.txt | 2 +
.../run_install_and_test_provider_packages.sh | 2 +-
setup.py | 1 +
tests/core/test_providers_manager.py | 1 +
.../{zendesk/hooks => apache/beam}/__init__.py | 0
.../{zendesk => apache/beam}/hooks/__init__.py | 0
tests/providers/apache/beam/hooks/test_beam.py | 271 ++++++++
.../hooks => apache/beam/operators}/__init__.py | 0
tests/providers/apache/beam/operators/test_beam.py | 274 ++++++++
.../apache/beam/operators/test_beam_system.py | 47 ++
.../providers/google/cloud/hooks/test_dataflow.py | 760 ++++++++++++---------
.../google/cloud/operators/test_dataflow.py | 223 ++++--
.../google/cloud/operators/test_mlengine_utils.py | 30 +-
33 files changed, 3049 insertions(+), 700 deletions(-)
create mode 100644 airflow/providers/apache/beam/BACKPORT_PROVIDER_README.md
copy airflow/providers/{zendesk => apache/beam}/CHANGELOG.rst (100%)
create mode 100644 airflow/providers/apache/beam/README.md
copy {tests/www/api/experimental => airflow/providers/apache/beam}/__init__.py
(100%)
copy {tests/www/api/experimental =>
airflow/providers/apache/beam/example_dags}/__init__.py (100%)
create mode 100644 airflow/providers/apache/beam/example_dags/example_beam.py
copy {tests/www/api/experimental =>
airflow/providers/apache/beam/hooks}/__init__.py (100%)
create mode 100644 airflow/providers/apache/beam/hooks/beam.py
copy {tests/www/api/experimental =>
airflow/providers/apache/beam/operators}/__init__.py (100%)
create mode 100644 airflow/providers/apache/beam/operators/beam.py
copy airflow/providers/{discord => apache/beam}/provider.yaml (65%)
copy docs/{apache-airflow-providers-apache-livy =>
apache-airflow-providers-apache-beam}/index.rst (83%)
create mode 100644 docs/apache-airflow-providers-apache-beam/operators.rst
copy tests/providers/{zendesk/hooks => apache/beam}/__init__.py (100%)
copy tests/providers/{zendesk => apache/beam}/hooks/__init__.py (100%)
create mode 100644 tests/providers/apache/beam/hooks/test_beam.py
copy tests/providers/{zendesk/hooks => apache/beam/operators}/__init__.py
(100%)
create mode 100644 tests/providers/apache/beam/operators/test_beam.py
create mode 100644 tests/providers/apache/beam/operators/test_beam_system.py
