This is an automated email from the ASF dual-hosted git repository.
kaxil pushed a change to branch aip99-crewai
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 90dc9bd5480 Drop crewai from workspace install path; users install
separately
discard 068f45a7105 Use dedicated crewai conn_type and reject
non-OpenAI-compatible providers
discard eb0f617559b Add CrewAI stock analysis example DAG using CrewAIHook
discard fa9dce4b593 Add CrewAI framework hook to common.ai provider
add 824722219b4 Fix provider executor tests broken in main (#67268)
add 75ca1714f96 fix: Support log level parsing from container output in
`EcsRunTaskOperator` (#67180)
add c91117a89b1 Prevent durable storage tests from leaking hook lineage
(#67252)
add f2af887699a Add ExecuteCallback support to AWS ECS Executor (#63657)
add 4325707b488 Add per-provider pre-extras install hook for native build
prereqs (#67205)
add 9b85d88749e Fix wrong changelog entry for BigQueryInsertJobOperator in
google provider 22.0.0 (#67280)
add ddf1ebc0fe7 fix: EksPodOperator 401 with cross-account AssumeRole via
aws_conn_id (#65335)
add 9288949db28 Add bulk delete Dag Runs (#67095)
add c3bf97d6a21 Fix duplicated logs and memory issue with S3 log handler
(#67144)
add 75a5877470f Add announcement step to PMC onboarding instructions
(#67303)
add ac5ab7da828 fix typo "@tash.bash" -> "@task.bash (#67301)
add a73c6268a3b Fix KubernetesPodTrigger.get_task_state KeyError on mapped
TIs (#67296) (#67297)
add ca05a56f6a1 Fix multiple_outputs no-op on deferrable
KubernetesPodOperator (#67226)
add 9cfd9943d68 Support timezone in SDK temporal partition mappers (#67164)
add 2e9cbc25ebb Add configurable task span detail level for OTel tracing
(#63568)
add 6886e5bd8ad Remove unused isLoggedIn and expectLoginSuccess from UI
e2e page objects (#67267)
add 8199e76a718 Fix EMR Serverless task failure on transient AWS
throttling errors (#67222)
add 93eee4fb31d i18n(ko): Improve Korean Task terminology consistency
(#67234)
add 8388bb8f89e Deprecate implicit REMOTE_TASK_LOG registration in
OpensearchTaskHandler (#67106)
add 9ed5a08fd1f AIP-76: Add example and docs for runtime asset
partitioning (#67307)
add d02b66523f2 Fix SageMaker processing stopped state handling (#67291)
add af5af564ffa Export from_timestamp from Task SDK timezone module
(#67321)
add 11ba5ec753b Breeze: bind api-server dual-stack so http://localhost
works in Chrome/Safari (#67320)
add 8c2fa492bc1 Add `allow_global` option to asset access control (#67251)
add 0b4818955d3 Add CrewAI framework hook to common.ai provider
add 953946f5950 Add CrewAI stock analysis example DAG using CrewAIHook
add e9a6797c86d Use dedicated crewai conn_type and reject
non-OpenAI-compatible providers
add 6c982c8f3ea Drop crewai from workspace install path; users install
separately
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 (90dc9bd5480)
\
N -- N -- N refs/heads/aip99-crewai (6c982c8f3ea)
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:
COMMITTERS.rst | 3 +-
Dockerfile.ci | 29 ++
.../docs/authoring-and-scheduling/assets.rst | 42 +++
airflow-core/docs/migrations-ref.rst | 4 +-
airflow-core/newsfragments/67164.significant.rst | 34 +++
.../api_fastapi/core_api/datamodels/dag_run.py | 13 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 328 +++++++++++++++------
.../api_fastapi/core_api/routes/public/dag_run.py | 28 +-
.../src/airflow/api_fastapi/core_api/security.py | 52 ++++
.../core_api/services/public/dag_run.py | 115 +++++++-
.../execution_api/routes/task_instances.py | 5 +-
airflow-core/src/airflow/assets/manager.py | 10 +-
.../src/airflow/dag_processing/collection.py | 12 +-
.../example_dags/example_asset_allow_teams.py | 8 +-
.../example_dags/example_asset_partition.py | 53 ++++
...rol_columns_to_dag_schedule_asset_reference.py} | 10 +-
airflow-core/src/airflow/models/asset.py | 3 +
airflow-core/src/airflow/models/dagrun.py | 25 +-
airflow-core/src/airflow/models/taskinstance.py | 10 +-
airflow-core/src/airflow/serialization/encoders.py | 3 +-
.../src/airflow/ui/openapi-gen/queries/common.ts | 17 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 26 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 26 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 76 +++--
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 26 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 170 ++++++++++-
.../ui/openapi-gen/requests/services.gen.ts | 98 +++---
.../airflow/ui/openapi-gen/requests/types.gen.ts | 154 +++++++---
.../airflow/ui/public/i18n/locales/ko/admin.json | 2 +-
.../airflow/ui/public/i18n/locales/ko/assets.json | 4 +-
.../airflow/ui/public/i18n/locales/ko/common.json | 20 +-
.../ui/public/i18n/locales/ko/components.json | 16 +-
.../src/airflow/ui/public/i18n/locales/ko/dag.json | 40 +--
.../airflow/ui/public/i18n/locales/ko/dags.json | 20 +-
.../airflow/ui/public/i18n/locales/ko/hitl.json | 2 +-
.../airflow/ui/public/i18n/locales/ko/tasks.json | 2 +-
.../src/components/MarkAs/Run/MarkRunAsButton.tsx | 4 +-
.../src/components/MarkAs/Run/MarkRunAsDialog.tsx | 4 +-
.../src/airflow/ui/src/components/MarkAs/utils.ts | 4 +-
.../BulkDeleteDagRunsButton.tsx} | 93 +++---
.../ui/src/pages/{ => DagRuns}/DagRuns.test.tsx | 0
.../airflow/ui/src/pages/{ => DagRuns}/DagRuns.tsx | 79 ++++-
.../ui/src/pages/{ => DagRuns}/DagRunsFilters.tsx | 0
.../ui/src/pages/{ => DagRuns}/DeleteRunButton.tsx | 0
.../Details/Gantt => pages/DagRuns}/index.ts | 3 +-
.../src/airflow/ui/src/pages/Run/Header.tsx | 2 +-
...ulkTaskInstances.ts => useBulkDeleteDagRuns.ts} | 52 ++--
.../src/airflow/ui/tests/e2e/pages/BasePage.ts | 10 -
.../src/airflow/ui/tests/e2e/pages/LoginPage.ts | 11 -
airflow-core/tests/integration/otel/test_otel.py | 78 ++++-
.../core_api/routes/public/test_dag_run.py | 274 ++++++++++++++++-
airflow-core/tests/unit/assets/test_manager.py | 57 +++-
.../tests/unit/dag_processing/test_collection.py | 10 +-
airflow-core/tests/unit/models/test_dagrun.py | 20 ++
.../tests/unit/models/test_taskinstance.py | 30 +-
.../tests/unit/partition_mappers/test_temporal.py | 136 ++++++++-
.../unit/serialization/test_serialized_objects.py | 79 ++++-
.../src/airflowctl/api/datamodels/generated.py | 93 +++++-
contributing-docs/12_provider_distributions.rst | 72 ++++-
.../aws/executors/aws_lambda/lambda_executor.py | 5 +-
.../amazon/aws/executors/batch/batch_executor.py | 5 +-
.../amazon/aws/executors/ecs/ecs_executor.py | 176 +++++++----
.../providers/amazon/aws/executors/ecs/utils.py | 61 ++--
.../src/airflow/providers/amazon/aws/hooks/eks.py | 24 +-
.../providers/amazon/aws/log/s3_task_handler.py | 6 +-
.../providers/amazon/aws/operators/sagemaker.py | 2 +-
.../airflow/providers/amazon/aws/triggers/ecs.py | 5 +-
.../providers/amazon/aws/utils/task_log_fetcher.py | 48 ++-
.../amazon/aws/utils/waiter_with_logging.py | 66 ++++-
.../executors/aws_lambda/test_lambda_executor.py | 10 +-
.../aws/executors/batch/test_batch_executor.py | 19 +-
.../amazon/aws/executors/ecs/test_ecs_executor.py | 283 +++++++++++++-----
.../amazon/tests/unit/amazon/aws/hooks/test_eks.py | 35 +++
.../unit/amazon/aws/log/test_s3_task_handler.py | 18 ++
.../aws/operators/test_sagemaker_processing.py | 28 ++
.../unit/amazon/aws/utils/test_task_log_fetcher.py | 124 +++++++-
.../amazon/aws/utils/test_waiter_with_logging.py | 53 ++++
.../unit/celery/executors/test_celery_executor.py | 2 +-
.../providers/cncf/kubernetes/operators/pod.py | 38 ++-
.../providers/cncf/kubernetes/triggers/pod.py | 10 +-
.../executors/test_kubernetes_executor.py | 2 +-
.../unit/cncf/kubernetes/operators/test_pod.py | 108 ++++++-
.../unit/cncf/kubernetes/triggers/test_pod.py | 86 +++++-
.../common/ai/tests/unit/common/ai/conftest.py | 12 +
providers/google/docs/changelog.rst | 2 +-
providers/opensearch/docs/changelog.rst | 8 +
providers/opensearch/docs/logging/index.rst | 36 ++-
.../providers/opensearch/log/os_task_handler.py | 25 ++
.../tests/unit/opensearch/log/conftest.py | 52 ++++
providers/standard/docs/operators/bash.rst | 2 +-
scripts/ci/docker-compose/integration-otel.yml | 2 +-
scripts/docker/entrypoint_ci.sh | 38 +++
scripts/in_container/bin/generate_mprocs_config.py | 14 +-
scripts/in_container/bin/run_tmux | 9 +-
scripts/in_container/run_pre_extras_install.py | 184 ++++++++++++
.../observability/traces/__init__.py | 35 ++-
.../tests/observability/test_traces.py | 104 +++++++
.../sdk/definitions/partition_mappers/temporal.py | 13 +
.../src/airflow/sdk/execution_time/task_runner.py | 66 ++++-
task-sdk/src/airflow/sdk/timezone.py | 2 +
.../task_sdk/execution_time/test_task_runner.py | 107 ++++++-
101 files changed, 3799 insertions(+), 723 deletions(-)
create mode 100644 airflow-core/newsfragments/67164.significant.rst
rename
airflow-core/src/airflow/migrations/versions/{0114_3_3_0_add_allow_producer_teams_to_dag_schedule_asset_reference.py
=> 0114_3_3_0_add_access_control_columns_to_dag_schedule_asset_reference.py}
(79%)
copy
airflow-core/src/airflow/ui/src/pages/{TaskInstances/BulkDeleteTaskInstancesButton.tsx
=> DagRuns/BulkDeleteDagRunsButton.tsx} (59%)
rename airflow-core/src/airflow/ui/src/pages/{ => DagRuns}/DagRuns.test.tsx
(100%)
rename airflow-core/src/airflow/ui/src/pages/{ => DagRuns}/DagRuns.tsx (82%)
rename airflow-core/src/airflow/ui/src/pages/{ => DagRuns}/DagRunsFilters.tsx
(100%)
rename airflow-core/src/airflow/ui/src/pages/{ => DagRuns}/DeleteRunButton.tsx
(100%)
copy airflow-core/src/airflow/ui/src/{layouts/Details/Gantt =>
pages/DagRuns}/index.ts (95%)
copy airflow-core/src/airflow/ui/src/queries/{useBulkTaskInstances.ts =>
useBulkDeleteDagRuns.ts} (65%)
create mode 100644 providers/opensearch/tests/unit/opensearch/log/conftest.py
create mode 100644 scripts/in_container/run_pre_extras_install.py
create mode 100644 shared/observability/tests/observability/test_traces.py
