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 165ea9ed0c4 [EDGE]CLI allows to retrieve status of worker (#46818)
add fece9c7dfc5 Create operators for working with Clusters for GCP Apache
Kafka (#45795)
No new revisions were added by this update.
Summary of changes:
generated/provider_dependencies.json | 1 +
providers/google/README.rst | 1 +
.../google/docs/operators/cloud/managed_kafka.rst | 78 ++++
providers/google/provider.yaml | 13 +
providers/google/pyproject.toml | 1 +
.../providers/google/cloud/hooks/managed_kafka.py | 288 +++++++++++++
.../cloud/links/{datastore.py => managed_kafka.py} | 36 +-
.../google/cloud/operators/managed_kafka.py | 451 +++++++++++++++++++++
.../airflow/providers/google/get_provider_info.py | 17 +
.../system/google/cloud/managed_kafka}/__init__.py | 0
.../managed_kafka/example_managed_kafka_cluster.py | 140 +++++++
.../unit/google/cloud/hooks/test_managed_kafka.py | 291 +++++++++++++
.../unit/google/cloud/links/test_managed_kafka.py | 89 ++++
.../google/cloud/operators/test_managed_kafka.py | 223 ++++++++++
tests/always/test_project_structure.py | 1 +
15 files changed, 1614 insertions(+), 16 deletions(-)
create mode 100644 providers/google/docs/operators/cloud/managed_kafka.rst
create mode 100644
providers/google/src/airflow/providers/google/cloud/hooks/managed_kafka.py
copy providers/google/src/airflow/providers/google/cloud/links/{datastore.py
=> managed_kafka.py} (62%)
create mode 100644
providers/google/src/airflow/providers/google/cloud/operators/managed_kafka.py
copy {airflow/api_connexion =>
providers/google/tests/system/google/cloud/managed_kafka}/__init__.py (100%)
create mode 100644
providers/google/tests/system/google/cloud/managed_kafka/example_managed_kafka_cluster.py
create mode 100644
providers/google/tests/unit/google/cloud/hooks/test_managed_kafka.py
create mode 100644
providers/google/tests/unit/google/cloud/links/test_managed_kafka.py
create mode 100644
providers/google/tests/unit/google/cloud/operators/test_managed_kafka.py
