This is an automated email from the ASF dual-hosted git repository.
potiuk 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 dd6de1cbdec Remove internal api call decorator from manager.py (#44491)
dd6de1cbdec is described below
commit dd6de1cbdeca6bfd1cd383b5a13aa839e910949b
Author: Shahar Epstein <60007259+shah...@users.noreply.github.com>
AuthorDate: Sat Nov 30 00:07:47 2024 +0200
Remove internal api call decorator from manager.py (#44491)
---
airflow/assets/manager.py | 4 ----
1 file changed, 4 deletions(-)
diff --git a/airflow/assets/manager.py b/airflow/assets/manager.py
index 0616d601511..40bc97b8134 100644
--- a/airflow/assets/manager.py
+++ b/airflow/assets/manager.py
@@ -23,7 +23,6 @@ from typing import TYPE_CHECKING
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 (
@@ -35,7 +34,6 @@ from airflow.models.asset import (
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
@@ -104,7 +102,6 @@ class AssetManager(LoggingMixin):
)
@classmethod
- @internal_api_call
def register_asset_change(
cls,
*,
@@ -122,7 +119,6 @@ class AssetManager(LoggingMixin):
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)
