This is an automated email from the ASF dual-hosted git repository.
mobuchowski pushed a change to branch openlineage-process-execution
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard a5ac1a4b48 openlineage: execute extraction and message sending in
separate process
discard ec1b19417c local task job: add timeout, to not kill
on_task_instance_success listener prematurely
add b03aa6caa0 Fix grammar in dags.rst (#40085)
add fe9159635f google: move openlineage imports inside methods (#40062)
add f2a5b1dee1 feat(providers/google): add default gcp_conn_id to
GoogleBaseAsyncHook (#40080)
add b358d0a6de Add `retry_args` parameter to `HttpOperator` (#40086)
add 0776bdbad1 Resolve google cloud kubernetes operator and trigger
deprecations in tests (#40072)
add 1a613030e6 Add task SLA and queued datetime information to
AirflowRunFacet (#40091)
add a31b10edda fix typo in example_params_ui_tutorial (#40094)
add 42a2b1a3bb Fix aws assume role session creation when deferrable
(#40051)
add 0568e9a604 Exit instead of return in case of Providers[fab] test is
ignored (#40089)
add 0e8d823a9f Remove apt-transport-https because It is a dummy
transitional package(#40015)
add 00a2843649 Include fatal reason for pod pending events (#39924)
add 013523e5d3 Fix credentials intialization revealed by mypy version of
google auth (#40108)
add 5bbd70cb45 Import aiobotocore locally in tests rather than as global
import (#40109)
add 8daa53eaa5 Avoid resetting adopted task instances when retrying for
kubernetes executor (#39406)
add 80522b91bb catch sentry flush if exception happens in _execute_in_fork
finally block (#40060)
add 4723dbe99a Use a join for TI notes in TI batch API endpoint (#40028)
add a3fc50d00b Remove obsolete conditional logic related to try_number
(#40104)
add 35bece7dc3 Prepare docs 1st wave June 2024 (#40057)
add 0c51bd6ab6 Upgrade to latest installers (#40107)
add f0128ced4c local task job: add timeout, to not kill
on_task_instance_success listener prematurely
add 2c96acba20 openlineage: execute extraction and message sending in
separate process
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (a5ac1a4b48)
\
N -- N -- N refs/heads/openlineage-process-execution (2c96acba20)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
Dockerfile | 2 +-
Dockerfile.ci | 6 +-
.../endpoints/task_instance_endpoint.py | 4 +-
airflow/example_dags/example_params_ui_tutorial.py | 6 +-
airflow/models/taskinstance.py | 8 -
airflow/providers/amazon/CHANGELOG.rst | 18 ++
airflow/providers/amazon/aws/hooks/base_aws.py | 11 +-
airflow/providers/celery/CHANGELOG.rst | 14 ++
airflow/providers/celery/__init__.py | 2 +-
.../celery/executors/celery_executor_utils.py | 8 +-
airflow/providers/celery/provider.yaml | 3 +-
airflow/providers/cncf/kubernetes/CHANGELOG.rst | 21 ++
airflow/providers/cncf/kubernetes/__init__.py | 2 +-
.../kubernetes/executors/kubernetes_executor.py | 18 +-
.../executors/kubernetes_executor_utils.py | 9 +-
airflow/providers/cncf/kubernetes/provider.yaml | 3 +-
.../hooks/vertex_ai/hyperparameter_tuning_job.py | 2 +-
.../cloud/openlineage/{utils.py => mixins.py} | 187 ++++--------------
.../providers/google/cloud/openlineage/utils.py | 219 +--------------------
.../providers/google/cloud/operators/bigquery.py | 3 +-
.../google/cloud/utils/credentials_provider.py | 19 +-
.../providers/google/common/hooks/base_google.py | 6 +-
.../google/common/utils/id_token_credentials.py | 2 +-
airflow/providers/http/operators/http.py | 18 +-
.../openlineage/facets/AirflowRunFacet.json | 7 +
airflow/providers/openlineage/utils/utils.py | 5 +-
docs/apache-airflow-providers-amazon/commits.rst | 20 +-
docs/apache-airflow-providers-amazon/index.rst | 10 +-
docs/apache-airflow-providers-celery/commits.rst | 16 +-
docs/apache-airflow-providers-celery/index.rst | 6 +-
.../commits.rst | 20 +-
.../index.rst | 4 +-
docs/apache-airflow/core-concepts/dags.rst | 6 +-
docs/apache-airflow/installation/dependencies.rst | 4 +-
scripts/docker/entrypoint_ci.sh | 2 +-
tests/deprecations_ignore.yml | 18 --
tests/providers/amazon/aws/hooks/test_base_aws.py | 12 +-
.../executors/test_kubernetes_executor.py | 27 +++
.../openlineage/{test_utils.py => test_mixins.py} | 116 +----------
.../google/cloud/openlineage/test_utils.py | 207 -------------------
.../cloud/operators/test_kubernetes_engine.py | 78 ++++++--
.../cloud/triggers/test_kubernetes_engine.py | 2 +-
tests/providers/http/operators/test_http.py | 71 +++++++
43 files changed, 429 insertions(+), 793 deletions(-)
copy airflow/providers/google/cloud/openlineage/{utils.py => mixins.py} (66%)
copy tests/providers/google/cloud/openlineage/{test_utils.py =>
test_mixins.py} (69%)
