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
from 8f9a17ddeac Bump version to be ready for 1.0.0-beta1 release
add 5e23c6a0cc8 Remove redundant session.commit() calls in FastAPI route
handlers (#69495)
add d3972ae1f6e Simplify airflowctl query parameter handling (#69475)
add 11b49e75593 Add extra field filtering for asset events (#64611)
add a050861fc59 Fix documentation misusing previous/next for task
relationships (#69179)
add 65fba6f1200 Add streaming task log support to BaseExecutor and
FileTaskHandler (#69299)
add 101bc155e0f Thread version_data to callbacks (#69185)
add dc5ddd26202 Add the team_name tag to the Celery executor
task_timeout_error (#69092)
add 01b425a06f6 Reject invalid partition keys in the create asset events
API (#69453)
add c96da9bb453 Skip the ts-sdk supervisor schema check on PRs not
touching ts-sdk (#69583)
add e5465795a88 Fix flaky KubernetesPodOperator log-timestamp test (#69563)
add 70913ba9727 Let area:kubernetes-tests label force the Kubernetes tests
job (#69519)
add 7dc3c2bfe0b Add supplied-token OIDC federation to the Databricks
provider (#69272)
add a0fd2ca4dd6 Remove unnecessary import alias (#69591)
add bc117abce10 Fix SSHRemoteJobOperator still orphaning the remote job on
cancellation (#69490)
add 2e56ce0712a Use task state store for `common.ai` durable execution on
Airflow 3.3+ (#68926)
add 6387f53744b Update python client version/changelog for 3.3.0 release
(#69600)
add a0284d47131 Fixing formatting of a code block in PMC checks for
providers (#69588)
add 50c44b5fcb9 Show Dag Run conf column by default in Dag Runs list
(#68904)
add 47056fe3804 Add quickstart to Anthropic provider (#69589)
add b15c4852bdb Document when to use common.ai vs vendor-specific AI
providers (#69551)
add 162952b3d3d Fix Java SDK RC2 blockers: source packaging, jar
LICENSE/NOTICE, BOM gap (#69582)
add 34520400a2c Remove unused span_status DB column and enum (#69278)
add b21e4299268 Migrate Airbyte provider to `airbyte-api` library 1.0 and
`httpx` (#68882)
add f1cc15564b9 Merge branch 'main' into java-sdk/1.0.0-beta1-release
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 +
...24_3_4_0_add_gin_index_on_asset_event_extra.py} | 41 ++--
...ag.py => 0125_3_4_0_drop_span_status_column.py} | 40 ++--
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 ++--
airflow-core/src/airflow/utils/span_status.py | 33 ---
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 | 0
.../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, 3321 insertions(+), 498 deletions(-)
copy
airflow-core/src/airflow/migrations/versions/{0090_3_2_0_add_length_dag_bundle_team_bundle_name.py
=> 0124_3_4_0_add_gin_index_on_asset_event_extra.py} (57%)
copy
airflow-core/src/airflow/migrations/versions/{0111_3_3_0_add_timetable_periodic_to_dag.py
=> 0125_3_4_0_drop_span_status_column.py} (53%)
delete mode 100644 airflow-core/src/airflow/utils/span_status.py
create mode 100644 providers/anthropic/docs/quickstart.rst
copy {airflow-core/src/airflow/_shared =>
providers/anthropic/src/airflow/providers/anthropic/example_dags}/__init__.py
(100%)
create mode 100644
providers/anthropic/src/airflow/providers/anthropic/example_dags/example_batch.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/durable/base.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/durable/task_state_store.py
create mode 100644
providers/common/ai/tests/unit/common/ai/durable/test_base.py
create mode 100644
providers/common/ai/tests/unit/common/ai/durable/test_task_state_store.py
