This is an automated email from the ASF dual-hosted git repository.
pierrejeambrun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 19ed5080673 Remove outdated TODO comment about permissions (#64169)
19ed5080673 is described below
commit 19ed5080673f47102847b2693b7c41cbc8ae7564
Author: Pierre Jeambrun <[email protected]>
AuthorDate: Wed Mar 25 12:03:29 2026 +0100
Remove outdated TODO comment about permissions (#64169)
---
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
