This is an automated email from the ASF dual-hosted git repository.
shahar1 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 2dffae53785 Remove unused active asset query helpers (#75778)
2dffae53785 is described below
commit 2dffae5378556689dd2433322a127a24e5a7da23
Author: Hussein Awala <[email protected]>
AuthorDate: Tue Oct 27 22:04:29 2026 +0100
Remove unused active asset query helpers (#75778)
Both standalone asset query helpers have no callers, registrations, or
documented public API contract. Asset reference resolution already uses the
active model lookup paths.
---
airflow-core/src/airflow/models/asset.py | 22 ----------------------
1 file changed, 22 deletions(-)
diff --git a/airflow-core/src/airflow/models/asset.py
b/airflow-core/src/airflow/models/asset.py
index df845b53a9f..47a7bf5b311 100644
--- a/airflow-core/src/airflow/models/asset.py
+++ b/airflow-core/src/airflow/models/asset.py
@@ -57,28 +57,6 @@ if TYPE_CHECKING:
from airflow.serialization.definitions.assets import SerializedAsset,
SerializedAssetAlias
-def fetch_active_assets_by_name(names: Iterable[str], session: Session) ->
dict[str, SerializedAsset]:
- return {
- asset_model.name: asset_model.to_serialized()
- for asset_model in session.scalars(
- select(AssetModel)
- .join(AssetActive, AssetActive.name == AssetModel.name)
- .where(AssetActive.name.in_(names))
- )
- }
-
-
-def fetch_active_assets_by_uri(uris: Iterable[str], session: Session) ->
dict[str, SerializedAsset]:
- return {
- asset_model.uri: asset_model.to_serialized()
- for asset_model in session.scalars(
- select(AssetModel)
- .join(AssetActive, AssetActive.uri == AssetModel.uri)
- .where(AssetActive.uri.in_(uris))
- )
- }
-
-
def expand_alias_to_assets(alias_name: str, *, session: Session) ->
Iterable[AssetModel]:
"""Expand asset alias to resolved assets."""
asset_alias_obj = session.scalar(
