File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 3535 import polars as pl
3636 from hsfs .transformation_function import TransformationFunction
3737
38- ONLINE_TOPIC_NAME_SUFFIX = "_onlinefs"
38+ _ONLINE_TOPIC_NAME_SUFFIX = "_onlinefs"
3939
4040
4141class FeatureGroupEngine (feature_group_base_engine .FeatureGroupBaseEngine ):
@@ -556,12 +556,12 @@ def _validate_topic_name(feature_group):
556556 if (
557557 feature_group .online_enabled
558558 and feature_group .topic_name is not None
559- and not feature_group .topic_name .endswith (ONLINE_TOPIC_NAME_SUFFIX )
559+ and not feature_group .topic_name .endswith (_ONLINE_TOPIC_NAME_SUFFIX )
560560 ):
561- corrected = feature_group .topic_name + ONLINE_TOPIC_NAME_SUFFIX
561+ corrected = feature_group .topic_name + _ONLINE_TOPIC_NAME_SUFFIX
562562 warnings .warn (
563563 f"Topic name '{ feature_group .topic_name } ' does not end with "
564- f"required suffix '{ ONLINE_TOPIC_NAME_SUFFIX } '. The suffix has "
564+ f"required suffix '{ _ONLINE_TOPIC_NAME_SUFFIX } '. The suffix has "
565565 f"been added automatically. Topic name set to: '{ corrected } '." ,
566566 util .FeatureGroupWarning ,
567567 stacklevel = 2 ,
You can’t perform that action at this time.
0 commit comments