This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a change to branch create-dask-executor-provider
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit e439272341 Extract Dask executor to new daskexecutor provider
omit a4fdf72b80 Quarantine test_backfill_integration in dask executor
add 01a61b0e7c Documentation Update to enhance readability (#32730)
add 505fe854e2 Remove unnecessary cast (#32782)
add 685328e357 Quarantine test_backfill_integration in dask executor
(#32780)
add 73bc49adb1 Fix depends_on_past work for dynamic tasks (#32397)
add 0339f94a50 Fix failing dagrun query due to sqlalchemy 2.0 refactor
(#32801)
add 6313e52932 Add missing execute_complete method for
`DatabricksRunNowOperator` (#32689)
add 6f75a8a917 improve performance of pr script in dev/stats (#32735)
add d05e42e5d2 Add `ExternalBranchPythonOperator` (#32787)
add 8012c9fce6 Add support for querying Redshift Serverless clusters
(#32785)
add 282854b55f Add endpoint_url in test_connection (#32664)
add 1706f05858 EMR serverless Create/Start/Stop/Delete Application
deferrable mode (#32513)
add 031e3945e4 Allow auth managers to override the security manager
(#32525)
add 2ac237b3eb Add pre-Airflow-2-7 hardcoded defaults for config for older
providers (#32775)
new bfafbe513a Extract Dask executor to new daskexecutor provider
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 (e439272341)
\
N -- N -- N refs/heads/create-dask-executor-provider (bfafbe513a)
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.
The 1 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:
airflow/api/auth/backend/session.py | 4 +-
airflow/auth/managers/base_auth_manager.py | 12 ++
airflow/auth/managers/fab/fab_auth_manager.py | 5 +
.../auth/managers/fab/security_manager_override.py | 220 ++++++++++++++++++++
airflow/cli/cli_config.py | 10 +-
airflow/config_templates/pre_2_7_defaults.cfg | 93 +++++++++
airflow/configuration.py | 61 +++++-
airflow/executors/kubernetes_executor.py | 2 +-
airflow/kubernetes/kubernetes_helper_functions.py | 2 +-
airflow/operators/python.py | 15 ++
airflow/providers/amazon/aws/hooks/base_aws.py | 6 +-
airflow/providers/amazon/aws/hooks/emr.py | 26 ++-
.../providers/amazon/aws/hooks/redshift_data.py | 10 +
airflow/providers/amazon/aws/operators/emr.py | 172 ++++++++++++++--
.../amazon/aws/operators/redshift_data.py | 7 +
airflow/providers/amazon/aws/triggers/emr.py | 144 ++++++++++++-
.../providers/celery/executors/celery_executor.py | 2 +-
.../celery/executors/celery_executor_utils.py | 24 +--
.../providers/databricks/operators/databricks.py | 7 +-
airflow/settings.py | 2 +-
airflow/ti_deps/deps/prev_dagrun_dep.py | 129 +++++++++---
airflow/utils/log/file_task_handler.py | 2 +-
airflow/utils/providers_configuration_loader.py | 13 +-
airflow/www/auth.py | 5 +-
airflow/www/decorators.py | 4 +-
airflow/www/extensions/init_appbuilder.py | 7 -
.../extensions/init_auth_manager.py} | 36 ++--
airflow/www/extensions/init_jinja_globals.py | 5 +-
airflow/www/extensions/init_security.py | 5 +-
airflow/www/fab_security/manager.py | 137 +------------
airflow/www/fab_security/sqla/manager.py | 2 +-
airflow/www/security.py | 40 +++-
airflow/www/views.py | 19 +-
dev/stats/get_important_pr_candidates.py | 228 +++++++++------------
.../operators/emr/emr_serverless.rst | 6 +
.../authoring-and-scheduling/plugins.rst | 1 -
tests/auh/managers/fab/test_fab_auth_manager.py | 4 +
.../auh/managers/test_base_auth_manager.py | 24 ++-
tests/core/test_configuration.py | 9 +-
tests/operators/test_python.py | 206 ++++++++++++++++++-
tests/providers/amazon/aws/hooks/test_base_aws.py | 20 +-
.../amazon/aws/hooks/test_redshift_data.py | 67 +++++-
.../amazon/aws/operators/test_emr_serverless.py | 73 ++++++-
.../amazon/aws/operators/test_redshift_data.py | 42 ++++
.../amazon/aws/triggers/test_emr_serverless.py | 29 +++
.../databricks/operators/test_databricks.py | 4 +-
tests/ti_deps/deps/test_prev_dagrun_dep.py | 123 ++++++-----
tests/www/views/test_views_tasks.py | 23 +++
48 files changed, 1595 insertions(+), 492 deletions(-)
create mode 100644 airflow/auth/managers/fab/security_manager_override.py
create mode 100644 airflow/config_templates/pre_2_7_defaults.cfg
copy airflow/{utils/weight_rule.py => www/extensions/init_auth_manager.py}
(58%)
copy airflow/kubernetes/pod_launcher.py =>
tests/auh/managers/test_base_auth_manager.py (66%)
