We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0a0a560 commit b859e16Copy full SHA for b859e16
python/hsfs/engine/spark.py
@@ -35,6 +35,7 @@
35
import tzlocal
36
from hopsworks_common.core.constants import HAS_NUMPY, HAS_PANDAS
37
from hsfs.constructor import query
38
+from hsfs.core import feature_group_api
39
40
# in case importing in %%local
41
from hsfs.core.vector_db_client import VectorDbClient
@@ -252,7 +253,7 @@ def reconcile_schema(
252
253
[feature.name for feature in fg_alias.feature_group._features] +
254
self.HUDI_SPEC_FEATURE_NAMES if fg_alias.feature_group.time_travel_format == "HUDI" else []
255
):
- full_fg = self._feature_group_api.get(
256
+ full_fg = feature_group_api.FeatureGroupApi().get(
257
feature_store_id=fg_alias.feature_group._feature_store_id,
258
name=fg_alias.feature_group.name,
259
version=fg_alias.feature_group.version,
0 commit comments