You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ra...@apache.org on 2026/04/15 11:52:26 UTC
(airflow) branch v3-2-test updated: Remove outdated TODO comment about permissions (#64169) (#65295)
This is an automated email from the ASF dual-hosted git repository.
rahulvats pushed a commit to branch v3-2-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-2-test by this push:
new 8ad8360798c Remove outdated TODO comment about permissions (#64169) (#65295)
8ad8360798c is described below
commit 8ad8360798c615550350fa0f8b5edb6d4c3e41c3
Author: Rahul Vats <43...@users.noreply.github.com>
AuthorDate: Wed Apr 15 17:22:18 2026 +0530
Remove outdated TODO comment about permissions (#64169) (#65295)
(cherry picked from commit 19ed5080673f47102847b2693b7c41cbc8ae7564)
Co-authored-by: Pierre Jeambrun <pi...@gmail.com>
---
airflow-core/src/airflow/api_fastapi/common/db/common.py | 10 ----------
1 file changed, 10 deletions(-)
diff --git a/airflow-core/src/airflow/api_fastapi/common/db/common.py b/airflow-core/src/airflow/api_fastapi/common/db/common.py
index 2fd7ac26f90..ff1e3f7043e 100644
--- a/airflow-core/src/airflow/api_fastapi/common/db/common.py
+++ b/airflow-core/src/airflow/api_fastapi/common/db/common.py
@@ -112,11 +112,6 @@ async def paginated_select_async(
if return_total_entries:
total_entries = await get_query_count_async(statement, session=session)
- # TODO: Re-enable when permissions are handled. Readable / writable entities,
- # for instance:
- # readable_dags = get_auth_manager().get_authorized_dag_ids(user=g.user)
- # dags_select = dags_select.where(DagModel.dag_id.in_(readable_dags))
-
statement = apply_filters_to_select(
statement=statement,
filters=[order_by, offset, limit],
@@ -171,11 +166,6 @@ def paginated_select(
if return_total_entries:
total_entries = get_query_count(statement, session=session)
- # TODO: Re-enable when permissions are handled. Readable / writable entities,
- # for instance:
- # readable_dags = get_auth_manager().get_authorized_dag_ids(user=g.user)
- # dags_select = dags_select.where(DagModel.dag_id.in_(readable_dags))
-
statement = apply_filters_to_select(statement=statement, filters=[order_by, offset, limit])
return statement, total_entries