This is an automated email from the ASF dual-hosted git repository.
uranusjr pushed a change to branch java-sdk/1.0.0-beta1-release
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard f1cc15564b9 Merge branch 'main' into java-sdk/1.0.0-beta1-release
omit b21e4299268 Migrate Airbyte provider to `airbyte-api` library 1.0 and
`httpx` (#68882)
omit 34520400a2c Remove unused span_status DB column and enum (#69278)
omit 162952b3d3d Fix Java SDK RC2 blockers: source packaging, jar
LICENSE/NOTICE, BOM gap (#69582)
omit b15c4852bdb Document when to use common.ai vs vendor-specific AI
providers (#69551)
omit 47056fe3804 Add quickstart to Anthropic provider (#69589)
omit 50c44b5fcb9 Show Dag Run conf column by default in Dag Runs list
(#68904)
omit a0284d47131 Fixing formatting of a code block in PMC checks for
providers (#69588)
omit 6387f53744b Update python client version/changelog for 3.3.0 release
(#69600)
omit 2e56ce0712a Use task state store for `common.ai` durable execution on
Airflow 3.3+ (#68926)
omit bc117abce10 Fix SSHRemoteJobOperator still orphaning the remote job on
cancellation (#69490)
omit a0fd2ca4dd6 Remove unnecessary import alias (#69591)
omit 7dc3c2bfe0b Add supplied-token OIDC federation to the Databricks
provider (#69272)
omit 70913ba9727 Let area:kubernetes-tests label force the Kubernetes tests
job (#69519)
omit e5465795a88 Fix flaky KubernetesPodOperator log-timestamp test (#69563)
omit c96da9bb453 Skip the ts-sdk supervisor schema check on PRs not
touching ts-sdk (#69583)
omit 01b425a06f6 Reject invalid partition keys in the create asset events
API (#69453)
omit dc5ddd26202 Add the team_name tag to the Celery executor
task_timeout_error (#69092)
omit 101bc155e0f Thread version_data to callbacks (#69185)
omit 65fba6f1200 Add streaming task log support to BaseExecutor and
FileTaskHandler (#69299)
omit a050861fc59 Fix documentation misusing previous/next for task
relationships (#69179)
omit 11b49e75593 Add extra field filtering for asset events (#64611)
omit d3972ae1f6e Simplify airflowctl query parameter handling (#69475)
omit 5e23c6a0cc8 Remove redundant session.commit() calls in FastAPI route
handlers (#69495)
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/java-sdk/1.0.0-beta1-release (8f9a17ddeac)
\
O -- O -- O (f1cc15564b9)
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:
.pre-commit-config.yaml | 1 +
.../docs/authoring-and-scheduling/assets.rst | 20 --
.../dynamic-task-mapping.rst | 4 +-
airflow-core/docs/best-practices.rst | 4 +-
airflow-core/docs/howto/dynamic-dag-generation.rst | 2 +-
airflow-core/docs/migrations-ref.rst | 6 +-
airflow-core/docs/tutorial/objectstorage.rst | 4 +-
airflow-core/docs/tutorial/taskflow.rst | 2 +-
.../src/airflow/api_fastapi/common/parameters.py | 56 -----
.../api_fastapi/core_api/datamodels/assets.py | 20 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 14 --
.../api_fastapi/core_api/routes/public/assets.py | 3 -
.../core_api/routes/public/backfills.py | 1 +
.../api_fastapi/core_api/routes/public/hitl.py | 2 +
.../execution_api/routes/asset_events.py | 38 +---
.../api_fastapi/execution_api/routes/hitl.py | 1 +
.../api_fastapi/execution_api/routes/xcoms.py | 1 +
.../src/airflow/callbacks/callback_requests.py | 2 -
airflow-core/src/airflow/dag_processing/manager.py | 6 +-
.../src/airflow/executors/base_executor.py | 14 --
.../src/airflow/executors/workloads/callback.py | 4 -
.../src/airflow/executors/workloads/task.py | 7 +-
.../src/airflow/jobs/scheduler_job_runner.py | 10 +-
airflow-core/src/airflow/migrations/env.py | 10 -
...124_3_4_0_add_gin_index_on_asset_event_extra.py | 57 -----
.../versions/0125_3_4_0_drop_span_status_column.py | 64 ------
airflow-core/src/airflow/models/dag_version.py | 14 +-
airflow-core/src/airflow/models/dagrun.py | 10 +-
airflow-core/src/airflow/models/taskinstance.py | 4 +
.../src/airflow/models/taskinstancehistory.py | 4 +
airflow-core/src/airflow/models/trigger.py | 27 +--
.../src/airflow/ui/openapi-gen/queries/common.ts | 5 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 6 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 6 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 6 +-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 6 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 4 +-
.../ui/openapi-gen/requests/services.gen.ts | 2 -
.../airflow/ui/openapi-gen/requests/types.gen.ts | 4 -
.../src/airflow/ui/src/pages/DagRuns/DagRuns.tsx | 1 +
airflow-core/src/airflow/utils/db.py | 1 -
.../src/airflow/utils/log/file_task_handler.py | 44 ++--
.../src/airflow/utils/span_status.py | 17 +-
airflow-core/src/airflow/utils/sqlalchemy.py | 55 +----
airflow-core/tests/integration/otel/test_otel.py | 9 +-
.../core_api/routes/public/test_assets.py | 105 ---------
.../versions/head/test_asset_events.py | 207 -----------------
.../tests/unit/callbacks/test_callback_requests.py | 27 ---
.../tests/unit/dag_processing/test_manager.py | 25 --
.../tests/unit/executors/test_base_executor.py | 8 -
.../tests/unit/executors/test_workloads.py | 60 +----
airflow-core/tests/unit/jobs/test_scheduler_job.py | 1 -
airflow-core/tests/unit/models/test_dag_version.py | 29 ---
.../tests/unit/models/test_taskinstance.py | 2 +
airflow-core/tests/unit/models/test_trigger.py | 27 ---
.../tests/unit/utils/log/test_file_task_handler.py | 74 ------
airflow-core/tests/unit/utils/test_db.py | 2 -
.../src/airflowctl/api/datamodels/generated.py | 6 +-
airflow-ctl/src/airflowctl/api/operations.py | 40 ++--
.../tests/airflow_ctl/api/test_operations.py | 16 +-
clients/python/CHANGELOG.md | 49 ----
clients/python/version.txt | 2 +-
contributing-docs/14_metadata_database_updates.rst | 4 +-
dev/README_RELEASE_PROVIDERS.md | 2 +-
dev/breeze/doc/ci/04_selective_checks.md | 5 -
.../src/airflow_breeze/utils/selective_checks.py | 17 +-
dev/breeze/tests/test_selective_checks.py | 111 ++-------
java-sdk/.gitattributes | 9 +-
java-sdk/README.md | 205 +++--------------
java-sdk/bom/build.gradle.kts | 47 ----
.../main/kotlin/airflow-jvm-conventions.gradle.kts | 14 --
providers/airbyte/README.rst | 10 +-
providers/airbyte/docs/changelog.rst | 20 --
providers/airbyte/docs/connections.rst | 5 +-
providers/airbyte/docs/index.rst | 10 +-
providers/airbyte/pyproject.toml | 7 +-
.../src/airflow/providers/airbyte/hooks/airbyte.py | 17 +-
.../tests/unit/airbyte/hooks/test_airbyte.py | 44 ++--
providers/amazon/docs/operators/ssm.rst | 4 +-
providers/anthropic/docs/index.rst | 36 ---
providers/anthropic/docs/quickstart.rst | 87 -------
.../providers/anthropic/example_dags/__init__.py | 16 --
.../anthropic/example_dags/example_batch.py | 57 -----
providers/apache/kafka/docs/index.rst | 1 -
.../providers/celery/executors/celery_executor.py | 3 +-
.../unit/celery/executors/test_celery_executor.py | 60 +----
.../unit/cncf/kubernetes/utils/test_pod_manager.py | 55 +++--
providers/common/ai/docs/index.rst | 40 ----
providers/common/ai/docs/operators/agent.rst | 63 ++----
providers/common/ai/provider.yaml | 18 +-
.../airflow/providers/common/ai/durable/base.py | 59 -----
.../providers/common/ai/durable/caching_model.py | 9 +-
.../providers/common/ai/durable/caching_toolset.py | 7 +-
.../airflow/providers/common/ai/durable/storage.py | 7 +-
.../common/ai/durable/task_state_store.py | 185 ---------------
.../providers/common/ai/get_provider_info.py | 2 +-
.../airflow/providers/common/ai/operators/agent.py | 47 ++--
.../ai/tests/unit/common/ai/durable/test_base.py | 46 ----
.../unit/common/ai/durable/test_caching_model.py | 9 +-
.../unit/common/ai/durable/test_caching_toolset.py | 13 +-
.../common/ai/durable/test_task_state_store.py | 252 ---------------------
.../tests/unit/common/ai/operators/test_agent.py | 73 +++---
.../databricks/docs/connections/databricks.rst | 41 ----
.../providers/databricks/hooks/databricks_base.py | 114 ++--------
.../unit/databricks/hooks/test_databricks_base.py | 228 +------------------
providers/openai/docs/index.rst | 35 ---
.../src/airflow/providers/ssh/utils/remote_job.py | 23 +-
.../ssh/tests/unit/ssh/utils/test_remote_job.py | 135 +++--------
.../ci/prek/known_airflow_core_utils_modules.txt | 1 +
scripts/cov/core_coverage.py | 1 +
scripts/in_container/run_migration_round_trip.py | 1 +
task-sdk/src/airflow/sdk/api/client.py | 12 +-
task-sdk/src/airflow/sdk/execution_time/comms.py | 2 -
task-sdk/src/airflow/sdk/execution_time/context.py | 8 -
.../airflow/sdk/execution_time/schema/schema.json | 69 ------
.../src/airflow/sdk/execution_time/supervisor.py | 2 -
task-sdk/tests/task_sdk/api/test_client.py | 62 -----
.../tests/task_sdk/execution_time/test_context.py | 45 ----
.../task_sdk/execution_time/test_supervisor.py | 88 -------
ts-sdk/src/generated/supervisor.ts | 20 --
uv.lock | 38 +++-
121 files changed, 440 insertions(+), 3419 deletions(-)
delete mode 100644
airflow-core/src/airflow/migrations/versions/0124_3_4_0_add_gin_index_on_asset_event_extra.py
delete mode 100644
airflow-core/src/airflow/migrations/versions/0125_3_4_0_drop_span_status_column.py
copy providers/amazon/src/airflow/providers/amazon/aws/utils/sagemaker.py =>
airflow-core/src/airflow/utils/span_status.py (75%)
delete mode 100644 providers/anthropic/docs/quickstart.rst
delete mode 100644
providers/anthropic/src/airflow/providers/anthropic/example_dags/__init__.py
delete mode 100644
providers/anthropic/src/airflow/providers/anthropic/example_dags/example_batch.py
delete mode 100644
providers/common/ai/src/airflow/providers/common/ai/durable/base.py
delete mode 100644
providers/common/ai/src/airflow/providers/common/ai/durable/task_state_store.py
delete mode 100644
providers/common/ai/tests/unit/common/ai/durable/test_base.py
delete mode 100644
providers/common/ai/tests/unit/common/ai/durable/test_task_state_store.py
