diff --git a/python/hsfs/feature_store.py b/python/hsfs/feature_store.py index d5c85cc52..4f7080fdb 100644 --- a/python/hsfs/feature_store.py +++ b/python/hsfs/feature_store.py @@ -630,7 +630,7 @@ def plus_two(value): periodically. The value can be either an integer representing the number of hours between each run or a string representing a cron expression. Set the value to None to avoid scheduling the materialization job. Defaults to None (i.e no scheduling). - storage_connector: the storage connector to use to establish connectivity + storage_connector: the storage connector used to establish connectivity with the data source. path: The location within the scope of the storage connector, from where to read the data for the external feature group @@ -793,7 +793,7 @@ def get_or_create_feature_group( periodically. The value can be either an integer representing the number of hours between each run or a string representing a cron expression. Set the value to None to avoid scheduling the materialization job. Defaults to None (i.e no automatic scheduling). Applies only on Feature Group creation. - storage_connector: the storage connector to use to establish connectivity + storage_connector: the storage connector used to establish connectivity with the data source. path: The location within the scope of the storage connector, from where to read the data for the external feature group @@ -877,7 +877,7 @@ def create_on_demand_feature_group( # Arguments name: Name of the external feature group to create. - storage_connector: the storage connector to use to establish connectivity + storage_connector: the storage connector used to establish connectivity with the data source. query: A string containing a SQL query valid for the target data source. the query will be used to pull data from the data sources when the @@ -1034,7 +1034,7 @@ def create_external_feature_group( # Arguments name: Name of the external feature group to create. - storage_connector: the storage connector to use to establish connectivity + storage_connector: the storage connector used to establish connectivity with the data source. query: A string containing a SQL query valid for the target data source. the query will be used to pull data from the data sources when the diff --git a/python/hsfs/storage_connector.py b/python/hsfs/storage_connector.py index 5f9d8c532..7a887cbba 100644 --- a/python/hsfs/storage_connector.py +++ b/python/hsfs/storage_connector.py @@ -136,7 +136,7 @@ def spark_options(self) -> None: def prepare_spark(self, path: Optional[str] = None) -> Optional[str]: _logger.info( - "This Storage Connector cannot be prepare for Spark." + "This Storage Connector cannot be prepared for Spark." ) return path