This is an automated email from the ASF dual-hosted git repository.
jason810496 pushed a change to branch
jason/lang-sdk-e2e/02b-shared-dag-cycle-detection
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 541001b9ee1 Share Dag cycle detection between the Task SDK and core
add e4d397f021e Bound get_schema results for very wide tables in the SQL
toolsets (#74017)
add 7d6244bf191 Clarify `max_db_retries` doc wording to avoid off-by-one
confusion (#73722)
add bb463bf9230 Correlate executor task events by attempt UUID (#73916)
add c19faf0c5ae Render the HITL review workflow as a Mermaid diagram
(#74024)
add 2aa31ae7bff Use airflow.sdk imports in Airflow 3 upgrade guide example
(#74015)
add f3532c60eda Use Task SDK TaskInstanceState in OpenSearch log handler
(#72444)
add 0ec26723858 Add GKEPodExecOperator for existing Pods (#72577)
add 740986adfce Add missing cycle assertion to test_semi_complex (#71973)
add fca1c01c73e Fix Windows UnicodeDecodeError during pytest collection
(#73536)
add 1787ef7cbba Run the deferred AWS hook configuration check as a prek
hook (#73681)
add 413ae46a045 Align timetable docs with Airflow 3 data interval and
catchup behaviour (#70658)
add 57e89c0a676 Share Dag cycle detection between the Task SDK and core
add e5ae872c9a1 Pin the empty task id case in the Dag cycle detection tests
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 (541001b9ee1)
\
N -- N -- N
refs/heads/jason/lang-sdk-e2e/02b-shared-dag-cycle-detection (e5ae872c9a1)
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:
.../docs/authoring-and-scheduling/timetable.rst | 154 ++++++---
airflow-core/docs/core-concepts/executor/index.rst | 23 +-
.../docs/installation/upgrading_to_airflow3.rst | 2 +-
.../src/airflow/config_templates/config.yml | 6 +-
.../src/airflow/executors/base_executor.py | 123 ++++++-
.../src/airflow/executors/local_executor.py | 13 +-
.../src/airflow/executors/workloads/task.py | 3 +-
.../src/airflow/executors/workloads/types.py | 17 +-
.../src/airflow/jobs/scheduler_job_runner.py | 49 +--
airflow-core/src/airflow/models/taskinstance.py | 2 +-
.../versions/head/test_task_instances.py | 5 +-
.../tests/unit/executors/test_base_executor.py | 278 +++++++++++++--
.../tests/unit/executors/test_local_executor.py | 10 +-
.../tests/unit/executors/test_workloads.py | 16 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 181 +++++++---
.../tests/unit/models/test_taskinstance.py | 12 +
devel-common/src/tests_common/pytest_plugin.py | 9 +-
.../src/tests_common/test_utils/mock_executor.py | 5 +-
.../src/tests_common/test_utils/providers.py | 2 +-
providers/.pre-commit-config.yaml | 7 +
.../amazon/aws/test_deferred_hook_configuration.py | 242 +------------
.../unit/celery/executors/test_celery_executor.py | 4 +
.../executors/test_kubernetes_executor.py | 2 +
providers/common/ai/docs/changelog.rst | 12 +
providers/common/ai/docs/hitl_review.rst | 63 ++--
providers/common/ai/docs/toolsets/datafusion.rst | 11 +-
providers/common/ai/docs/toolsets/sql.rst | 41 ++-
.../providers/common/ai/toolsets/datafusion.py | 35 +-
.../airflow/providers/common/ai/toolsets/sql.py | 33 +-
.../providers/common/ai/utils/query_results.py | 202 ++++++++++-
.../unit/common/ai/toolsets/test_datafusion.py | 55 ++-
.../ai/tests/unit/common/ai/toolsets/test_sql.py | 62 +++-
.../unit/common/ai/utils/test_query_results.py | 167 ++++++++-
providers/google/docs/index.rst | 8 +-
.../docs/operators/cloud/kubernetes_engine.rst | 20 ++
providers/google/pyproject.toml | 2 +-
.../google/cloud/operators/kubernetes_engine.py | 114 +++++++
.../kubernetes_engine/example_kubernetes_engine.py | 105 +++++-
.../cloud/operators/test_kubernetes_engine.py | 146 +++++++-
.../providers/opensearch/log/os_task_handler.py | 3 +-
.../ci/prek/check_deferred_hook_configuration.py | 294 ++++++++++++++++
scripts/ci/prek/common_prek_utils.py | 26 +-
scripts/ci/prek/update_providers_dependencies.py | 14 +-
.../prek/test_check_deferred_hook_configuration.py | 373 +++++++++++++++++++++
shared/dagnode/tests/dagnode/test_cycle.py | 10 +-
task-sdk/tests/task_sdk/definitions/test_dag.py | 2 +
46 files changed, 2456 insertions(+), 507 deletions(-)
create mode 100755 scripts/ci/prek/check_deferred_hook_configuration.py
create mode 100644
scripts/tests/ci/prek/test_check_deferred_hook_configuration.py
