Skip to content

Removed deprecated method reference airflow.www.auth.has_access when min airflow version >= 2.8.0 #41747

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
potiuk merged 1 commit into from
Aug 27, 2024
Merged

Removed deprecated method reference airflow.www.auth.has_access when min airflow version >= 2.8.0 #41747

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 0 additions & 12 deletions airflow/providers/databricks/plugins/databricks_workflow.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,6 @@

from flask import current_app, flash, redirect, request, url_for
from flask_appbuilder.api import expose
from packaging.version import Version

from airflow.exceptions import AirflowException, TaskInstanceNotFound
from airflow.models import BaseOperator, BaseOperatorLink
Expand All @@ -34,13 +33,11 @@
from airflow.models.xcom import XCom
from airflow.plugins_manager import AirflowPlugin
from airflow.providers.databricks.hooks.databricks import DatabricksHook
from airflow.security import permissions
from airflow.utils.airflow_flask_app import AirflowApp
from airflow.utils.log.logging_mixin import LoggingMixin
from airflow.utils.session import NEW_SESSION, provide_session
from airflow.utils.state import TaskInstanceState
from airflow.utils.task_group import TaskGroup
from airflow.version import version
from airflow.www import auth
from airflow.www.views import AirflowBaseView

Expand All @@ -55,15 +52,6 @@


def get_auth_decorator():
# TODO: remove this if block when min_airflow_version is set to higher than 2.8.0
if Version(version) < Version("2.8"):
return auth.has_access(
[
(permissions.ACTION_CAN_EDIT, permissions.RESOURCE_DAG),
(permissions.ACTION_CAN_CREATE, permissions.RESOURCE_DAG_RUN),
]
)

from airflow.auth.managers.models.resource_details import DagAccessEntity

return auth.has_access_dag("POST", DagAccessEntity.RUN)
Expand Down