This is an automated email from the ASF dual-hosted git repository.
Lee-W pushed a change to branch backfill-empty-window-ux
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard cab5b94330b Return 422 for empty partitioned backfill window and fix
dry-run drift
add ff52f44e92b Fix N+1 queries in trigger asset event submission (#65367)
add 1667c6b356f Introducing object store backend for task and asset state
store (#68283)
add b176ec91dc5 Gate provider release on artifact completeness check
before vote (#69141)
add 3b13e593ac6 Fix cursor pagination dropping rows when sorting by a
nullable column (#68869)
add 052c26b046f Bump the fab-ui-package-updates group across 1 directory
with 3 updates (#69133)
add 7790bb52994 Fix Dag detail page 500 for Dags without a fileloc #69035
(#69110)
add bfd7689273d Add OpenLineage system tests for new emission_policy
feature (#69181)
add 2e50d6e5f48 Bump the fab-ui-package-updates group across 1 directory
with 3 updates (#69186)
add 0bfc7eac0e8 Fix `SSHRemoteJobOperator` orphaning the remote job on
cancellation (#68644)
add efc3844e981 Add tests for CoordinatorManager configuration error paths
(#69184)
add 1161cf9b004 prevent path traversal in s3 to sftp/ftp transfer
destinations (#68984)
add ddd9ec84277 Add Amazon Provider Neptune Analytics (#64274)
add 4074028cd81 Make test fixtures clean up the bundle and team rows they
create (#69093)
add 73700f08d04 Fix drifting data intervals for monthly/yearly schedules
with catchup disabled (#69143)
add e0a1726aa58 [main] Upgrade important CI environment (#68933)
add 8cf93a56193 Fix nil sdk.XComClient injected into Go SDK tasks (#69192)
add a3f51fcd9ce Accept BLOCKED and WAITING_FOR_RETRY Databricks run states
(#69193)
add d0b456cdf9c Add Scala Spark ETL example to Java-SDK e2e tests (#68939)
add 579aa9f0915 Reconnect to blocked Databricks runs in SubmitRunOperator
durable retries (#69195)
add 794cbd8b51c Add durable execution to `DatabricksRunNowOperator`
(#69174)
add 62ca5d9746f Fix hll import in openlineage system tests (#69196)
add ceaa65e76f4 Remove obsolete committer onboarding steps (#69201)
add 687134f3803 Java SDK: Serialize coordinator client send/receive for
thread safety (#69080)
add 080afb7d98d Fix the translation Gap for Taiwanese Mandarin (#69199)
add 578c1a61830 Fix macOS `SIGSEGV` in triggerer and DAG processor via
`fork+exec` (#69008)
add f86b03c3077 Add Multi-Lang KubernetesExecutor system test (#68709)
add 594604681b2 Fix mypy failure on datadog timer wrapped by shared
observability Timer (#69202)
add a8770ba5668 Update SQLAlchemy documentation links from 1.4 to 2.0
(#69200)
add 3daa88e9502 Use oracledb AuthMode/Purity enums in Oracle hook
connection config (#67689)
add 3eecc4c8c6d Resolve dict-via-variable trigger serialize() in static
check (#67300)
add bb4da3272e4 Breeze: Add scope metadata to GitHub token retrieval
(#66753)
add 46186d28912 Fix connection resolution in CLI by setting server process
context in decorators (#61036)
add b8cb62a651f Warm-shutdown supervisor on SIGTERM instead of killing the
running task (#69034)
add 7ede795680b Update schema versions (#68509)
add 5eaf78bd629 Add team_name tags to Kubernetes executor metrics (#69046)
add 2257e956912 Fix KubernetesExecutor leaking a Manager process when
reading running task logs (#68800)
add d2d9f4c2d83 Improve API server HTTPRoute configuration (#68552)
add e8a6db188cd Sync magpie-setup bootstrap skill to current apache-magpie
framework (#69209)
add ecd6fd4ad24 Add airflowctl dags state command (#68564)
add adb541ca663 Add new Committers to CODEOWNERS (#69215)
add b006a978d20 Add task.execute detail span around task execute callable
(#67877)
add 5d4453dcaff MSgraph: fix UnicodeDecodeError in DefaultResponseHandler
when response content is binary (#68495)
add 9b8c03f6739 Trim redundant comments from KubernetesExecutor
lazy-Manager tests (#69216)
add 98f89a04976 Mark dags details for airflowctl (#68529)
add ec5f19d4999 Add a test verifying that SnowparkOperator closes the
Snowpark (#68775)
add b3678b3354e SnowflakeSqlApiOperator: add XCom query ID test coverage
(#68731)
add ff10b2e3e19 Honor catchup for historical asset events in
asset-triggered Dags (#68749)
add 37f6259b708 Fix mapped task group XCom collapsing to a bare value for
a single expansion (#69075)
add 9ecca013c9a Triggerer: strengthen triggerer metric test coverage
(#68545)
add bfba4eb26fd Fix lang-SDK KubernetesExecutor system test reverting
api-server auth manager (#69221)
add b448e6ec582 Clarify when last_automated_data_interval is None in
timetable docs (#68461)
add e01986326c1 Skip pnpm install in UI pre-commit hook when deps are
unchanged (#64124)
add e577860a743 Remove stale metrics no longer emitted from the metrics
registry (#68945)
add e29d36f527b Add `env_provider` and `Extra.env` support to MCP stdio
transport (#69225)
add 54f4300bcd0 Guard JSONB migration against invalid bytes conversion
(#69064)
add d161a4934da Refactor UI translation files to use nested keys for
DRYness (#68285)
add fa9e5c7aaca Fix Java SDK numeric XCom casting and remove unused XCom
key field (#68983)
add d5ccb62e386 Point provider agents at the cross-provider
dependency-bump rule (#69218)
add 17aa5415c7c Mark providers commands for airflowctl (#68525)
new 6ccb4f6059a Return 422 for empty partitioned backfill window and fix
dry-run drift
new 658e19021da Rewrite misleading logic
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 (cab5b94330b)
\
N -- N -- N refs/heads/backfill-empty-window-ux (658e19021da)
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.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.agents/skills/magpie-setup/SKILL.md | 20 +-
.agents/skills/magpie-setup/adopt.md | 171 +-
.agents/skills/magpie-setup/overrides.md | 4 +-
.agents/skills/magpie-setup/unadopt.md | 85 +-
.agents/skills/magpie-setup/upgrade.md | 91 +-
.agents/skills/magpie-setup/verify.md | 50 +-
.agents/skills/magpie-setup/worktree-init.md | 52 +-
.github/CODEOWNERS | 12 +-
.github/workflows/k8s-tests.yml | 3 +
.github/zizmor.yml | 6 +
.pre-commit-config.yaml | 7 +-
COMMITTERS.rst | 8 +-
Dockerfile | 2 +-
Dockerfile.ci | 2 +-
airflow-core/docs/best-practices.rst | 2 +-
airflow-core/docs/howto/set-up-database.rst | 12 +-
airflow-core/docs/howto/timetable.rst | 9 +
airflow-core/newsfragments/68749.bugfix.rst | 1 +
airflow-core/newsfragments/69075.bugfix.rst | 1 +
airflow-core/newsfragments/69143.bugfix.rst | 1 +
.../src/airflow/api_fastapi/common/cursors.py | 66 +-
.../api_fastapi/core_api/datamodels/dags.py | 2 +-
.../api_fastapi/core_api/openapi/_private_ui.yaml | 4 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 8 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 7 +-
.../core_api/routes/public/task_instances.py | 11 +-
airflow-core/src/airflow/assets/manager.py | 2 +-
.../src/airflow/cli/commands/dag_command.py | 1 +
.../src/airflow/cli/commands/provider_command.py | 3 +
.../src/airflow/dag_processing/processor.py | 14 +-
.../src/airflow/jobs/scheduler_job_runner.py | 14 +-
.../src/airflow/jobs/triggerer_job_runner.py | 13 +-
...49_3_0_0_remove_pickled_data_from_xcom_table.py | 190 +-
..._3_0_0_remove_pickled_data_from_dagrun_table.py | 37 +-
airflow-core/src/airflow/models/base.py | 2 +-
airflow-core/src/airflow/models/trigger.py | 6 +-
airflow-core/src/airflow/timetables/base.py | 3 +
airflow-core/src/airflow/timetables/interval.py | 26 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 27 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 6 +-
.../airflow/ui/public/i18n/locales/en/admin.json | 32 +-
.../airflow/ui/public/i18n/locales/en/common.json | 12 +-
.../airflow/ui/public/i18n/locales/en/dags.json | 12 +-
.../ui/public/i18n/locales/zh-TW/common.json | 41 +
.../airflow/ui/public/i18n/locales/zh-TW/dag.json | 4 +-
.../Code/FileLocation.test.tsx} | 27 +-
.../airflow/ui/src/pages/Dag/Code/FileLocation.tsx | 14 +-
airflow-core/src/airflow/utils/cli.py | 13 +-
.../tests/unit/api_fastapi/common/test_cursors.py | 123 +-
.../core_api/routes/public/test_dag_run.py | 34 +
.../core_api/routes/public/test_dags.py | 20 +
.../core_api/routes/public/test_task_instances.py | 101 +
.../unit/cli/commands/test_command_deprecations.py | 5 +-
.../cli/commands/test_dag_processor_command.py | 23 +
.../tests/unit/dag_processing/test_processor.py | 46 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 123 +-
airflow-core/tests/unit/jobs/test_triggerer_job.py | 58 +-
...est_0049_remove_pickled_data_from_xcom_table.py | 150 ++
...t_0055_remove_pickled_data_from_dagrun_table.py | 143 ++
airflow-core/tests/unit/models/test_backfill.py | 6 +-
airflow-core/tests/unit/models/test_trigger.py | 22 +
.../unit/timetables/test_interval_timetable.py | 84 +
.../airflowctl_tests/test_airflowctl_commands.py | 4 +-
airflow-ctl/docs/images/command_hashes.txt | 2 +-
airflow-ctl/docs/images/output_dags.svg | 130 +-
airflow-ctl/src/airflowctl/api/client.py | 3 +-
.../src/airflowctl/api/datamodels/generated.py | 4 +-
airflow-ctl/src/airflowctl/api/operations.py | 21 +-
airflow-ctl/src/airflowctl/ctl/cli_config.py | 14 +
.../src/airflowctl/ctl/commands/dag_command.py | 57 +-
airflow-ctl/src/airflowctl/ctl/help_texts.yaml | 1 +
airflow-ctl/tests/airflow_ctl/api/test_client.py | 30 +-
.../tests/airflow_ctl/api/test_operations.py | 36 +
.../airflow_ctl/ctl/commands/test_dag_command.py | 117 ++
airflow-e2e-tests/docker/Dockerfile.java | 5 +-
airflow-e2e-tests/docker/java.yml | 12 +-
.../tests/airflow_e2e_tests/conftest.py | 105 +-
.../tests/airflow_e2e_tests/constants.py | 6 +
.../java_sdk_tests/test_java_sdk_dag.py | 120 ++
chart/docs/production-guide.rst | 14 +-
chart/files/pod-template-file.kubernetes-helm-yaml | 10 +
chart/newsfragments/69034.significant.rst | 7 +
.../templates/api-server/api-server-httproute.yaml | 29 +-
chart/templates/api-server/api-server-ingress.yaml | 3 +
chart/tests/chart_utils/helm_template_generator.py | 3 +
.../airflow_aux/test_pod_template_file.py | 11 +
.../apiserver/test_httproute_apiserver.py | 215 ++-
chart/values.schema.json | 198 +-
chart/values.yaml | 94 +-
chart/values_schema.schema.json | 2 +-
contributing-docs/testing/unit_tests.rst | 60 +
dev/README_RELEASE_PROVIDERS.md | 14 +
dev/breeze/doc/05_test_commands.rst | 17 +
dev/breeze/doc/ci/02_images.md | 2 +-
dev/breeze/doc/images/output_k8s.svg | 38 +-
dev/breeze/doc/images/output_k8s.txt | 2 +-
.../doc/images/output_k8s_run-complete-tests.svg | 72 +-
.../doc/images/output_k8s_run-complete-tests.txt | 2 +-
.../doc/images/output_k8s_setup-lang-sdk-test.svg | 152 ++
.../doc/images/output_k8s_setup-lang-sdk-test.txt | 1 +
.../output_setup_check-all-params-in-groups.svg | 4 +-
.../output_setup_check-all-params-in-groups.txt | 2 +-
.../output_setup_regenerate-command-images.svg | 8 +-
.../output_setup_regenerate-command-images.txt | 2 +-
.../src/airflow_breeze/commands/ci_commands.py | 7 +-
.../src/airflow_breeze/commands/issues_commands.py | 7 +-
.../airflow_breeze/commands/kubernetes_commands.py | 504 ++++-
.../commands/kubernetes_commands_config.py | 21 +-
.../commands/release_management_commands.py | 26 +-
dev/breeze/src/airflow_breeze/global_constants.py | 2 +-
.../src/airflow_breeze/utils/custom_param_types.py | 4 +-
dev/breeze/src/airflow_breeze/utils/github.py | 18 +-
.../airflow_breeze/utils/provider_dependencies.py | 10 +-
dev/breeze/tests/test_github_utils.py | 25 +-
dev/breeze/uv.lock | 130 +-
devel-common/pyproject.toml | 2 +-
devel-common/src/tests_common/pytest_plugin.py | 110 +-
docker-stack-docs/entrypoint.rst | 9 +
docs/spelling_wordlist.txt | 10 +
generated/provider_dependencies.json.sha256sum | 1 +
go-sdk/bundle/bundlev1/registry.go | 4 +-
go-sdk/bundle/bundlev1/task.go | 4 +-
go-sdk/bundle/bundlev1/task_test.go | 7 +
.../apache/airflow/example/AnnotationExample.java | 24 +
.../airflow/example/ExampleBundleBuilder.java | 5 +-
.../apache/airflow/example/XComCastingExample.java | 77 +
.../example/src/resources/dags/java_examples.py | 41 +
.../org/apache/airflow/sdk/BuilderProcessor.kt | 46 +-
.../kotlin/org/apache/airflow/sdk/BuilderTest.kt | 65 +-
java-sdk/scala_spark_example/README.md | 78 +
.../{example => scala_spark_example}/build.gradle | 30 +-
.../gradle.properties | 0
.../settings.gradle | 2 +-
.../main/resources/dags/scala_spark_examples.py | 24 +-
.../src/main/resources/log4j2.xml | 33 +-
.../apache/airflow/example/ScalaSparkExample.scala | 149 ++
.../main/kotlin/org/apache/airflow/sdk/Builder.kt | 2 -
.../org/apache/airflow/sdk/execution/Comm.kt | 25 +-
.../org/apache/airflow/sdk/execution/CommTest.kt | 107 ++
.../lang_sdk}/Dockerfile.java | 16 +-
kubernetes-tests/lang_sdk/README.md | 103 +
kubernetes-tests/lang_sdk/config/values.yaml | 74 +
.../lang_sdk/dags/lang_sdk_combined.py | 80 +
kubernetes-tests/lang_sdk/go_example/.gitignore | 3 +
.../lang_sdk/go_example}/go.mod | 73 +-
.../lang_sdk/go_example}/go.sum | 13 +-
kubernetes-tests/lang_sdk/go_example/main.go | 88 +
kubernetes-tests/lang_sdk/java_example/.gitignore | 3 +
.../lang_sdk/java_example}/build.gradle | 4 +-
.../lang_sdk/java_example/gradle.properties | 2 +
.../lang_sdk/java_example}/settings.gradle | 2 +-
.../apache/airflow/k8sexample/CombinedExample.java | 47 +
.../airflow/k8sexample/K8sBundleBuilder.java | 10 +-
.../lang_sdk/manifests/localstack.yaml | 77 +
.../lang_sdk/pod_templates/lang_sdk_golang.yaml | 66 +-
.../lang_sdk/pod_templates/lang_sdk_java.yaml | 64 +-
kubernetes-tests/lang_sdk/stage_artifacts.py | 92 +
.../test_lang_sdk_coordinator_executor.py | 88 +
providers/AGENTS.md | 1 +
.../amazon/docs/operators/neptune_analytics.rst | 148 ++
providers/amazon/provider.yaml | 13 +
.../src/airflow/providers/amazon/aws/exceptions.py | 24 +
...ensearch_serverless.py => neptune_analytics.py} | 21 +-
.../src/airflow/providers/amazon/aws/links/ec2.py | 11 +
.../links/{comprehend.py => neptune_analytics.py} | 23 +-
.../amazon/aws/operators/neptune_analytics.py | 1028 ++++++++++
.../providers/amazon/aws/transfers/s3_to_ftp.py | 2 +
.../providers/amazon/aws/transfers/s3_to_sftp.py | 2 +
.../amazon/aws/triggers/neptune_analytics.py | 282 +++
.../airflow/providers/amazon/aws/utils/__init__.py | 26 +
.../{stepfunctions.json => neptune_analytics.json} | 28 +-
.../airflow/providers/amazon/get_provider_info.py | 25 +-
.../system/amazon/aws/example_neptune_analytics.py | 346 ++++
.../amazon/aws/hooks/test_neptune_analytics.py | 62 +
.../amazon/tests/unit/amazon/aws/links/test_ec2.py | 29 +-
...unified_studio.py => test_neptune_analytics.py} | 19 +-
.../amazon/aws/operators/test_neptune_analytics.py | 1277 +++++++++++++
.../unit/amazon/aws/transfers/test_s3_to_ftp.py | 20 +
.../unit/amazon/aws/transfers/test_s3_to_sftp.py | 20 +
.../amazon/aws/triggers/test_neptune_analytics.py | 343 ++++
.../kubernetes/executors/kubernetes_executor.py | 36 +-
.../executors/kubernetes_executor_utils.py | 64 +-
.../executors/test_kubernetes_executor.py | 451 ++++-
providers/common/ai/README.rst | 2 +-
providers/common/ai/docs/connections/mcp.rst | 67 +-
providers/common/ai/docs/index.rst | 2 +-
providers/common/ai/docs/toolsets.rst | 13 +-
providers/common/ai/pyproject.toml | 4 +-
.../common/ai/example_dags/example_mcp.py | 41 +
.../src/airflow/providers/common/ai/hooks/mcp.py | 86 +-
.../airflow/providers/common/ai/toolsets/mcp.py | 21 +-
.../ai/tests/unit/common/ai/hooks/test_mcp.py | 207 +-
.../ai/tests/unit/common/ai/toolsets/test_mcp.py | 22 +-
providers/common/io/docs/index.rst | 1 +
providers/common/io/docs/state_store_backend.rst | 81 +
providers/common/io/provider.yaml | 28 +
.../providers/common/io/get_provider_info.py | 21 +
.../providers/common/io/state_store}/__init__.py | 0
.../providers/common/io/state_store/backend.py | 246 +++
.../tests/unit/common/io/state_store}/__init__.py | 0
.../unit/common/io/state_store/test_backend.py | 274 +++
providers/databricks/docs/operators/run_now.rst | 39 +
.../providers/databricks/hooks/databricks.py | 2 +
.../providers/databricks/operators/databricks.py | 107 +-
.../tests/unit/databricks/hooks/test_databricks.py | 2 +-
.../unit/databricks/operators/test_databricks.py | 289 ++-
providers/exasol/README.rst | 2 +-
providers/exasol/docs/index.rst | 2 +-
providers/exasol/pyproject.toml | 4 +-
.../fab/src/airflow/providers/fab/www/package.json | 10 +-
.../src/airflow/providers/fab/www/pnpm-lock.yaml | 478 ++---
.../providers/microsoft/azure/hooks/msgraph.py | 2 +-
.../unit/microsoft/azure/hooks/test_msgraph.py | 12 +
... example_openlineage_policy_conf_locked_dag.py} | 17 +-
...ple_openlineage_policy_conf_source_code_dag.py} | 21 +-
...ample_openlineage_policy_dag_emit_false_dag.py} | 21 +-
...ple_openlineage_policy_dag_events_false_dag.py} | 31 +-
...le_openlineage_policy_dag_override_task_dag.py} | 17 +-
...ple_openlineage_policy_extract_metadata_dag.py} | 46 +-
...ample_openlineage_policy_full_task_info_dag.py} | 15 +-
.../example_openlineage_policy_hook_lineage_dag.py | 107 ++
... example_openlineage_policy_source_code_dag.py} | 28 +-
...mple_openlineage_policy_task_emit_false_dag.py} | 26 +-
.../openlineage_policy_conf_locked_dag.json | 26 +
.../openlineage_policy_conf_source_code_dag.json | 50 +
.../openlineage_policy_dag_emit_false_dag.json | 65 +
.../openlineage_policy_dag_events_false_dag.json | 69 +
.../openlineage_policy_dag_override_task_dag.json | 50 +
.../openlineage_policy_extract_metadata_dag.json | 50 +
... => openlineage_policy_full_task_info_dag.json} | 20 +-
.../openlineage_policy_hook_lineage_dag.json | 174 ++
.../openlineage_policy_source_code_dag.json | 68 +
.../openlineage_policy_task_emit_false_dag.json | 57 +
providers/oracle/README.rst | 2 +-
providers/oracle/docs/index.rst | 2 +-
providers/oracle/pyproject.toml | 2 +-
.../src/airflow/providers/oracle/hooks/oracle.py | 40 +-
.../unit/snowflake/decorators/test_snowpark.py | 32 +-
.../unit/snowflake/operators/test_snowflake.py | 30 +
.../unit/snowflake/operators/test_snowpark.py | 52 +-
.../tests/unit/snowflake/utils/test_snowpark.py | 2 +-
.../src/airflow/providers/sqlite/hooks/sqlite.py | 4 +-
.../src/airflow/providers/ssh/utils/remote_job.py | 52 +-
.../ssh/tests/unit/ssh/utils/test_remote_job.py | 90 +-
pyproject.toml | 2 +-
scripts/ci/prek/check_imports_in_providers.py | 2 +-
scripts/ci/prek/check_trigger_serialize_init.py | 138 +-
scripts/ci/prek/ruff_format.py | 2 +-
scripts/ci/prek/ts_compile_lint_ui.py | 30 +-
.../ci/prek/test_check_trigger_serialize_init.py | 326 ++++
scripts/tools/setup_breeze | 2 +-
.../observability/metrics/metrics_template.yaml | 18 -
.../observability/metrics/protocols.py | 10 +-
task-sdk/src/airflow/sdk/definitions/xcom_arg.py | 12 +-
.../src/airflow/sdk/execution_time/coordinator.py | 68 +-
.../src/airflow/sdk/execution_time/supervisor.py | 108 +-
.../src/airflow/sdk/execution_time/task_runner.py | 66 +-
.../serializers/{uuid.py => lazy_xcom_sequence.py} | 24 +-
.../tests/task_sdk/dags/signal_forward_test.py | 44 -
.../task_sdk/definitions/test_mappedoperator.py | 10 +
.../tests/task_sdk/definitions/test_xcom_arg.py | 68 +-
.../task_sdk/execution_time/test_coordinator.py | 189 ++
.../task_sdk/execution_time/test_supervisor.py | 90 +-
.../task_sdk/execution_time/test_task_runner.py | 140 ++
uv.lock | 2014 +++++++++++---------
265 files changed, 14507 insertions(+), 2705 deletions(-)
create mode 100644 airflow-core/newsfragments/68749.bugfix.rst
create mode 100644 airflow-core/newsfragments/69075.bugfix.rst
create mode 100644 airflow-core/newsfragments/69143.bugfix.rst
copy
airflow-core/src/airflow/ui/src/pages/{Connections/NothingFoundInfo.test.tsx =>
Dag/Code/FileLocation.test.tsx} (59%)
create mode 100644
airflow-core/tests/unit/migrations/test_0049_remove_pickled_data_from_xcom_table.py
create mode 100644
airflow-core/tests/unit/migrations/test_0055_remove_pickled_data_from_dagrun_table.py
create mode 100644 chart/newsfragments/69034.significant.rst
create mode 100644 dev/breeze/doc/images/output_k8s_setup-lang-sdk-test.svg
create mode 100644 dev/breeze/doc/images/output_k8s_setup-lang-sdk-test.txt
create mode 100644 generated/provider_dependencies.json.sha256sum
create mode 100644
java-sdk/example/src/java/org/apache/airflow/example/XComCastingExample.java
create mode 100644 java-sdk/scala_spark_example/README.md
copy java-sdk/{example => scala_spark_example}/build.gradle (51%)
copy java-sdk/{example => scala_spark_example}/gradle.properties (100%)
copy java-sdk/{example => scala_spark_example}/settings.gradle (95%)
copy airflow-core/src/airflow/example_dags/example_simplest_dag.py =>
java-sdk/scala_spark_example/src/main/resources/dags/scala_spark_examples.py
(74%)
copy dev/templates/example_dags_template.txt.jinja2 =>
java-sdk/scala_spark_example/src/main/resources/log4j2.xml (53%)
create mode 100644
java-sdk/scala_spark_example/src/main/scala/org/apache/airflow/example/ScalaSparkExample.scala
copy {airflow-e2e-tests/docker => kubernetes-tests/lang_sdk}/Dockerfile.java
(64%)
create mode 100644 kubernetes-tests/lang_sdk/README.md
create mode 100644 kubernetes-tests/lang_sdk/config/values.yaml
create mode 100644 kubernetes-tests/lang_sdk/dags/lang_sdk_combined.py
create mode 100644 kubernetes-tests/lang_sdk/go_example/.gitignore
copy {go-sdk => kubernetes-tests/lang_sdk/go_example}/go.mod (51%)
copy {go-sdk => kubernetes-tests/lang_sdk/go_example}/go.sum (93%)
create mode 100644 kubernetes-tests/lang_sdk/go_example/main.go
create mode 100644 kubernetes-tests/lang_sdk/java_example/.gitignore
copy {java-sdk/example => kubernetes-tests/lang_sdk/java_example}/build.gradle
(90%)
copy airflow-core/src/airflow/api_fastapi/auth/__init__.py =>
kubernetes-tests/lang_sdk/java_example/gradle.properties (96%)
copy {java-sdk/example =>
kubernetes-tests/lang_sdk/java_example}/settings.gradle (95%)
create mode 100644
kubernetes-tests/lang_sdk/java_example/src/java/org/apache/airflow/k8sexample/CombinedExample.java
copy
java-sdk/example/src/java/org/apache/airflow/example/ExampleBundleBuilder.java
=>
kubernetes-tests/lang_sdk/java_example/src/java/org/apache/airflow/k8sexample/K8sBundleBuilder.java
(77%)
create mode 100644 kubernetes-tests/lang_sdk/manifests/localstack.yaml
copy
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/kubernetes_executor_templates/basic_template.yaml
=> kubernetes-tests/lang_sdk/pod_templates/lang_sdk_golang.yaml (50%)
copy
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/kubernetes_executor_templates/basic_template.yaml
=> kubernetes-tests/lang_sdk/pod_templates/lang_sdk_java.yaml (51%)
create mode 100644 kubernetes-tests/lang_sdk/stage_artifacts.py
create mode 100644
kubernetes-tests/tests/kubernetes_tests/test_lang_sdk_coordinator_executor.py
create mode 100644 providers/amazon/docs/operators/neptune_analytics.rst
copy
providers/amazon/src/airflow/providers/amazon/aws/hooks/{opensearch_serverless.py
=> neptune_analytics.py} (68%)
copy providers/amazon/src/airflow/providers/amazon/aws/links/{comprehend.py =>
neptune_analytics.py} (61%)
create mode 100644
providers/amazon/src/airflow/providers/amazon/aws/operators/neptune_analytics.py
create mode 100644
providers/amazon/src/airflow/providers/amazon/aws/triggers/neptune_analytics.py
copy
providers/amazon/src/airflow/providers/amazon/aws/waiters/{stepfunctions.json
=> neptune_analytics.json} (66%)
create mode 100644
providers/amazon/tests/system/amazon/aws/example_neptune_analytics.py
create mode 100644
providers/amazon/tests/unit/amazon/aws/hooks/test_neptune_analytics.py
copy
providers/amazon/tests/unit/amazon/aws/links/{test_sagemaker_unified_studio.py
=> test_neptune_analytics.py} (78%)
create mode 100644
providers/amazon/tests/unit/amazon/aws/operators/test_neptune_analytics.py
create mode 100644
providers/amazon/tests/unit/amazon/aws/triggers/test_neptune_analytics.py
create mode 100644 providers/common/io/docs/state_store_backend.rst
copy {airflow-core/src/airflow/_shared =>
providers/common/io/src/airflow/providers/common/io/state_store}/__init__.py
(100%)
create mode 100644
providers/common/io/src/airflow/providers/common/io/state_store/backend.py
copy {airflow-core/src/airflow/_shared =>
providers/common/io/tests/unit/common/io/state_store}/__init__.py (100%)
create mode 100644
providers/common/io/tests/unit/common/io/state_store/test_backend.py
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_docs_file_dag.py
=> example_openlineage_policy_conf_locked_dag.py} (72%)
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_docs_file_dag.py
=> example_openlineage_policy_conf_source_code_dag.py} (66%)
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_versioned_dag.py
=> example_openlineage_policy_dag_emit_false_dag.py} (73%)
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_base_simple_dag.py
=> example_openlineage_policy_dag_events_false_dag.py} (59%)
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_docs_file_dag.py
=> example_openlineage_policy_dag_override_task_dag.py} (70%)
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_setup_teardown_dag.py
=> example_openlineage_policy_extract_metadata_dag.py} (56%)
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_docs_file_dag.py
=> example_openlineage_policy_full_task_info_dag.py} (77%)
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_hook_lineage_dag.py
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_docs_file_dag.py
=> example_openlineage_policy_source_code_dag.py} (60%)
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_base_simple_dag.py
=> example_openlineage_policy_task_emit_false_dag.py} (72%)
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_conf_locked_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_conf_source_code_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_dag_emit_false_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_dag_events_false_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_dag_override_task_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_extract_metadata_dag.json
copy
providers/openlineage/tests/system/openlineage/expected_events/{openlineage_mapped_simple_dag.json
=> openlineage_policy_full_task_info_dag.json} (52%)
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_hook_lineage_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_source_code_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_task_emit_false_dag.json
create mode 100644 scripts/tests/ci/prek/test_check_trigger_serialize_init.py
copy task-sdk/src/airflow/sdk/serde/serializers/{uuid.py =>
lazy_xcom_sequence.py} (63%)
delete mode 100644 task-sdk/tests/task_sdk/dags/signal_forward_test.py
