This is an automated email from the ASF dual-hosted git repository.
ephraimanierobi pushed a change to branch v2-3-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 881ac77082 Better behaviour for self-update of Breeze (#25572)
new bf9f4e1282 Clear next method when clearing TIs (#23929)
new 658f5abe60 Don't rely on current ORM structure for db clean command
(#23574)
new 394ebc80b5 Send DAG timeout callbacks to processor outside of
prohibit_commit (#24366)
new d9ca589649 Doc: Add hyperlinks to Github PRs for Release Notes (#24532)
new 8a95092c9e TriggerDagRunOperator.operator_extra_links is attr (#24676)
new 03b2fad778 Update PythonVirtualenvOperator Howto (#24782)
new 98baf6054b Note how DAG policy works with default_args (#24804)
new 9b4eec2a0e Add %z for %(asctime)s to fix timezone for logs on UI
(#24811)
new a720e4fb97 Bind log server on worker to IPv6 address (#24755) (#24846)
new 9b6df301ac Fix zombie task handling with multiple schedulers (#24906)
new 9a5f8739f3 Fix tag link on dag detail page (#24918)
new 481877a564 Fix syntax in mysql setup documentation (#24893 (#24939)
new 977d11dbed Extends resolve_xcom_backend function level documentation
(#24965)
new 651b43513a Update set-up-database.rst (#24983)
new f2a6915393 Sort operator extra links (#24992)
new 48de9c7791 Update 2.3.3 date in release notes (#25004)
new 0eec87e2b3 chore: fix typo (#25010)
new 7d2e516eaf No grid auto-refresh for backfill dag runs (#25042)
new b96e53a420 airflow/www/package.json: Add name, version fields. (#25065)
new af702bf69c Fix invalidateQueries call (#25097)
new 637af6a06d Added logging to get better diagnosis of flaky backfill
test (#25106)
new 975dd0c8a2 Stop SLA callbacks gazumping other callbacks and DOS'ing
the DagProcessorManager queue (#25147)
new 2f6d9ff25c call updateNodeLabels after expandGroup (#25217)
new 4316387086 convert TimeSensorAsync target_time to utc on call time
(#25221)
new 6567b3248f Only load distribution of a name once (#25296)
new de68fd1a81 Add __repr__ to ParamsDict class (#25305)
new 605126ce00 fix - resolve bash by absolute path (#25331)
new 385f04ba34 Fix Serialization error in TaskCallbackRequest (#25471)
new 18f13384f1 Fix "This Session's transaction has been rolled back"
(#25532)
new 6821fe12f8 Allow wildcarded CORS origins (#25553)
new 23c714b0c2 Fix the errors raised when None is passed to template
filters (#25593)
new b6a2cd1aa3 Configurable umask to all deamonized processes. (#25664)
new cf448ea174 Adding mysql index hint to use index on task_instance.state
in critical section query (#25673)
new 78fa95ca33 Don't mistakenly take a lock on DagRun via
ti.refresh_from_fb (#25312)
new 626814aec8 Refactor DR.task_instance_scheduling_decisions (#24774)
new aff5994e2b Remove useless logging line (#25347)
new ef5b4c9623 Removed interfering force of index. (#25404)
new 146d5109b4 Added exception catching to send default email if template
file raises any exception (#24943)
new dffcb5d5cd set default task group in dag.add_task method (#25000)
new cfce076abd fix: change disable_verify_ssl behaviour (#25023)
new 5c2fce92f4 Fix `airflow db reset` when dangling tables exist (#25441)
new 31a4b8cf1f Fix reducing mapped length of a mapped task at runtime
after a clear (#25531)
new 530a7ce802 Add right padding (#25554)
new ed9bf28d49 Cache the custom secrets backend so the same instance gets
re-used (#25556)
new 4a8d13997f Fix mapped sensor with reschedule mode (#25594)
The 45 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:
RELEASE_NOTES.rst | 2 +-
.../api_connexion/endpoints/extra_link_endpoint.py | 2 +-
airflow/callbacks/callback_requests.py | 2 +-
airflow/cli/cli_parser.py | 7 +-
airflow/cli/commands/celery_command.py | 3 +
airflow/cli/commands/dag_processor_command.py | 2 +
airflow/cli/commands/db_command.py | 1 +
airflow/cli/commands/kerberos_command.py | 1 +
airflow/cli/commands/scheduler_command.py | 1 +
airflow/cli/commands/triggerer_command.py | 1 +
airflow/cli/commands/webserver_command.py | 1 +
airflow/config_templates/airflow_local_settings.py | 11 +-
airflow/config_templates/config.yml | 28 ++-
airflow/config_templates/default_airflow.cfg | 14 +-
airflow/configuration.py | 19 +-
airflow/dag_processing/manager.py | 41 +++-
airflow/dag_processing/processor.py | 1 -
airflow/jobs/scheduler_job.py | 10 +-
airflow/kubernetes/kube_client.py | 11 +-
airflow/models/dag.py | 19 +-
airflow/models/dagrun.py | 83 ++++---
airflow/models/param.py | 3 +
airflow/models/taskinstance.py | 49 +++-
airflow/models/taskmixin.py | 6 +-
airflow/models/taskreschedule.py | 1 +
airflow/models/xcom.py | 6 +-
airflow/operators/bash.py | 4 +-
airflow/operators/trigger_dagrun.py | 6 +-
airflow/plugins_manager.py | 2 +-
airflow/sensors/time_sensor.py | 4 +-
airflow/serialization/serialized_objects.py | 2 +-
airflow/settings.py | 2 +
airflow/templates.py | 24 +-
airflow/ti_deps/deps/ready_to_reschedule.py | 11 +-
airflow/utils/db.py | 20 +-
airflow/utils/db_cleanup.py | 270 ++++++++++++---------
airflow/utils/entry_points.py | 22 +-
airflow/utils/log/timezone_aware.py | 49 ++++
airflow/utils/serve_logs.py | 22 +-
airflow/www/extensions/init_views.py | 8 +-
airflow/www/package.json | 2 +
airflow/www/static/js/graph.js | 1 +
airflow/www/static/js/grid/Grid.tsx | 1 +
airflow/www/static/js/grid/api/useClearTask.js | 2 +-
airflow/www/static/js/grid/api/useGridData.test.js | 30 ++-
airflow/www/static/js/grid/api/useGridData.ts | 2 +-
.../www/static/js/grid/api/useMarkFailedTask.js | 2 +-
.../www/static/js/grid/api/useMarkSuccessTask.js | 2 +-
airflow/www/static/js/grid/api/useRunTask.js | 2 +-
airflow/www/static/js/ti_log.js | 4 +-
airflow/www/templates/airflow/dag_details.html | 2 +-
docs/apache-airflow/concepts/cluster-policies.rst | 4 +
docs/apache-airflow/howto/operator/python.rst | 3 +-
docs/apache-airflow/howto/set-up-database.rst | 6 +-
docs/apache-airflow/static/gh-jira-links.js | 2 +-
docs/apache-airflow/tutorial.rst | 2 +-
docs/apache-airflow/usage-cli.rst | 2 +
docs/helm-chart/static/gh-jira-links.js | 2 +-
newsfragments/23574.feature.rst | 1 +
newsfragments/24755.improvement.rst | 1 +
newsfragments/24811.significant.rst | 22 ++
newsfragments/25147.bugfix.rst | 1 +
tests/api_connexion/test_cors.py | 140 +++++++++++
tests/callbacks/test_callback_requests.py | 21 +-
tests/cli/commands/test_celery_command.py | 1 +
tests/cli/commands/test_db_command.py | 34 ++-
tests/cli/commands/test_kerberos_command.py | 1 +
tests/core/test_configuration.py | 81 +++++++
tests/dag_processing/test_manager.py | 62 +++++
tests/jobs/test_backfill_job.py | 5 +-
tests/jobs/test_scheduler_job.py | 95 ++++++--
tests/kubernetes/test_client.py | 13 +
tests/models/test_cleartasks.py | 23 ++
tests/models/test_dag.py | 14 ++
tests/models/test_dagrun.py | 64 +++++
tests/models/test_param.py | 4 +
tests/models/test_taskinstance.py | 251 +++++++++++++++++++
tests/plugins/test_plugins_manager.py | 3 +-
tests/sensors/test_time_sensor.py | 7 +
tests/serialization/test_dag_serialization.py | 28 +++
tests/test_utils/db.py | 10 +-
tests/ti_deps/deps/test_ready_to_reschedule_dep.py | 81 ++++++-
tests/utils/test_db_cleanup.py | 44 +++-
tests/utils/test_entry_points.py | 49 ++++
tests/www/views/test_views.py | 2 +-
85 files changed, 1593 insertions(+), 307 deletions(-)
create mode 100644 airflow/utils/log/timezone_aware.py
create mode 100644 newsfragments/23574.feature.rst
create mode 100644 newsfragments/24755.improvement.rst
create mode 100644 newsfragments/24811.significant.rst
create mode 100644 newsfragments/25147.bugfix.rst
create mode 100644 tests/api_connexion/test_cors.py
create mode 100644 tests/utils/test_entry_points.py