You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by as...@apache.org on 2025/02/06 15:01:12 UTC
(airflow) branch mapped-tasks-tasksdk-execution-time updated (1e973530a66 -> 1af18517e37)
This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch mapped-tasks-tasksdk-execution-time
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 1e973530a66 Add dynamic task mapping into TaskSDK runtime
add 9aa330909ba AIP-83: Restore Uniqueness Constraint on Logical Date, Make It Nullable (#46295)
add 39d5c55a462 Handle null logical date in CLI commands (#46407)
add 96f64168c37 Add `lock` to `BaseDagBundle` and use it in `GitDagBundle` (#46501)
add 09ba0b14e52 docs: clarify Gunicorn's role in webserver worker refresh (#46371)
add 18ec6ab79f2 Allow passing empty labels in the spark kubernetes driver config (#45864)
add e16418b6c43 SnowflakeSqlApiOperator snowflake_conn_id add to template_fields (#46422)
add ee8d6658f86 Replace Airflow email config by connection extras in SMTP provider (#46219)
add a9287d390c1 Integrate the SimpleAuthManager UI in dev mode (#46511)
add 12325000260 AIP-84 Remove unecessary datamodels config and from_attributes (#46328)
add 7340b066187 Fix scheduler ServiceAccount automount for multi-executor (#46486)
add c813c32feb3 Add update XCom endpoint in RestAPI (#46457)
add fe30f87954f Fix missing logical_date in DagRun for DMS operator tests (#46521)
add 1af18517e37 Add dynamic task mapping into TaskSDK runtime
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 (1e973530a66)
\
N -- N -- N refs/heads/mapped-tasks-tasksdk-execution-time (1af18517e37)
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:
.../api_fastapi/core_api/datamodels/dag_tags.py | 4 -
.../api_fastapi/core_api/datamodels/event_logs.py | 4 +-
.../core_api/datamodels/import_error.py | 4 +-
airflow/api_fastapi/core_api/datamodels/pools.py | 4 +-
.../core_api/datamodels/task_instances.py | 5 -
.../api_fastapi/core_api/datamodels/variables.py | 4 +-
airflow/api_fastapi/core_api/datamodels/xcom.py | 7 ++
.../api_fastapi/core_api/openapi/v1-generated.yaml | 88 ++++++++++++++++++
airflow/api_fastapi/core_api/routes/public/job.py | 9 +-
.../core_api/routes/public/task_instances.py | 11 +--
airflow/api_fastapi/core_api/routes/public/xcom.py | 46 +++++++++
.../execution_api/routes/task_instances.py | 3 +-
.../{ => auth/managers/simple}/ui/dev/index.html | 8 +-
airflow/auth/managers/simple/ui/package.json | 2 +-
airflow/cli/cli_config.py | 2 +-
.../cli/commands/remote_commands/dag_command.py | 36 ++++---
.../cli/commands/remote_commands/task_command.py | 62 ++-----------
airflow/cli/utils.py | 54 ++++++++++-
airflow/config_templates/config.yml | 6 +-
airflow/dag_processing/bundles/base.py | 39 +++++++-
airflow/dag_processing/bundles/git.py | 34 +++----
...execution_date_to_logical_date_and_nullable.py} | 15 ++-
airflow/models/dag.py | 2 +-
airflow/models/dagrun.py | 11 ++-
airflow/ui/openapi-gen/queries/common.ts | 3 +
airflow/ui/openapi-gen/queries/queries.ts | 56 +++++++++++
airflow/ui/openapi-gen/requests/schemas.gen.ts | 18 ++++
airflow/ui/openapi-gen/requests/services.gen.ts | 36 +++++++
airflow/ui/openapi-gen/requests/types.gen.ts | 47 ++++++++++
.../scheduler/scheduler-serviceaccount.yaml | 2 +-
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
docs/apache-airflow/img/airflow_erd.svg | 1 -
docs/apache-airflow/migrations-ref.rst | 2 +-
helm_tests/airflow_core/test_scheduler.py | 3 +-
.../providers/snowflake/operators/snowflake.py | 5 +
.../kubernetes/operators/custom_object_launcher.py | 2 +-
providers/src/airflow/providers/smtp/CHANGELOG.rst | 22 +++++
providers/src/airflow/providers/smtp/hooks/smtp.py | 22 ++---
.../airflow/providers/smtp/notifications/smtp.py | 29 +++---
providers/src/airflow/providers/smtp/provider.yaml | 40 --------
providers/tests/amazon/aws/operators/test_dms.py | 26 ++++--
.../operators/test_custom_object_launcher.py | 28 ++++--
providers/tests/smtp/hooks/test_smtp.py | 103 +++++++--------------
providers/tests/smtp/notifications/test_smtp.py | 54 +----------
scripts/ci/pre_commit/compile_ui_assets_dev.py | 44 ++++++++-
.../src/airflow/sdk/execution_time/task_runner.py | 2 +-
task_sdk/src/airflow/sdk/types.py | 2 +-
tests/api_fastapi/conftest.py | 8 +-
.../core_api/routes/public/test_assets.py | 10 +-
.../core_api/routes/public/test_dag_run.py | 44 +++++----
.../core_api/routes/public/test_task_instances.py | 21 +++--
.../core_api/routes/public/test_xcom.py | 41 ++++++++
.../commands/remote_commands/test_dag_command.py | 2 +
.../commands/remote_commands/test_task_command.py | 20 ++--
tests/dag_processing/test_dag_bundles.py | 86 +++++++++++++++--
tests/models/test_backfill.py | 5 +
tests/models/test_dagrun.py | 1 +
tests/models/test_taskinstance.py | 24 ++++-
tests/www/views/test_views_tasks.py | 3 +
tests_common/test_utils/version_compat.py | 1 +
60 files changed, 852 insertions(+), 423 deletions(-)
copy airflow/{ => auth/managers/simple}/ui/dev/index.html (76%)
rename airflow/migrations/versions/{0032_3_0_0_drop_execution_date_unique.py => 0032_3_0_0_rename_execution_date_to_logical_date_and_nullable.py} (84%)