You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2022/02/13 11:19:21 UTC
[airflow] branch main updated (cca2f94 -> da485da)
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 cca2f94 Add mssql-cli to devel extra in Airflow (#21520)
add da485da Add support for BeamGoPipelineOperator (#20386)
No new revisions were added by this update.
Summary of changes:
.../apache/beam/example_dags/example_beam.py | 114 +++++-
airflow/providers/apache/beam/hooks/beam.py | 51 ++-
airflow/providers/apache/beam/operators/beam.py | 385 ++++++++++++++-------
airflow/providers/google/cloud/hooks/dataflow.py | 2 +-
airflow/providers/google/cloud/hooks/gcs.py | 4 +-
.../providers/google/cloud/operators/dataflow.py | 6 +-
airflow/providers/google/go_module_utils.py | 46 +++
airflow/utils/process_utils.py | 9 +-
.../operators.rst | 48 +++
docs/spelling_wordlist.txt | 1 +
setup.py | 2 +-
tests/providers/apache/beam/hooks/test_beam.py | 56 ++-
tests/providers/apache/beam/operators/test_beam.py | 142 ++++++++
.../apache/beam/operators/test_beam_system.py | 6 +
tests/providers/google/cloud/hooks/test_gcs.py | 2 +-
.../test_s3_list.py => google/test_go_module.py} | 34 +-
tests/utils/test_process_utils.py | 24 +-
17 files changed, 748 insertions(+), 184 deletions(-)
create mode 100644 airflow/providers/google/go_module_utils.py
copy tests/providers/{amazon/aws/operators/test_s3_list.py => google/test_go_module.py} (50%)