Skip to content

Commit

Permalink
Remove internal api call decorator from manager.py (apache#44491)
Browse files Browse the repository at this point in the history
  • Loading branch information
shahar1 authored Nov 29, 2024
1 parent 2bc8617 commit dd6de1c
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions airflow/assets/manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,6 @@
from sqlalchemy import exc, select
from sqlalchemy.orm import joinedload

from airflow.api_internal.internal_api_call import internal_api_call
from airflow.configuration import conf
from airflow.listeners.listener import get_listener_manager
from airflow.models.asset import (
Expand All @@ -35,7 +34,6 @@
DagScheduleAssetReference,
)
from airflow.models.dagbag import DagPriorityParsingRequest
from airflow.sdk.definitions.asset import Asset
from airflow.stats import Stats
from airflow.utils.log.logging_mixin import LoggingMixin

Expand Down Expand Up @@ -104,7 +102,6 @@ def _add_asset_alias_association(
)

@classmethod
@internal_api_call
def register_asset_change(
cls,
*,
Expand All @@ -122,7 +119,6 @@ def register_asset_change(
For local assets, look them up, record the asset event, queue dagruns, and broadcast
the asset event
"""
# todo: add test so that all usages of internal_api_call are added to rpc endpoint
asset_model = session.scalar(
select(AssetModel)
.where(AssetModel.uri == asset.uri)
Expand Down

0 comments on commit dd6de1c

Please sign in to comment.