@@ -82,9 +82,9 @@ def transform(input_feature_group, input_csv):
8282 inputs (Sequence[Union[FeatureGroupDataSource, CSVDataSource, ParquetDataSource,
8383 BaseDataSource]]): A list of data sources.
8484 output (str): A Feature Group ARN to write results of this function to.
85- target_stores (Optional[list[str]], optional): A list containing at least one of
86- 'OnlineStore' or 'OfflineStore'. If unspecified, data will be ingested to the enabled
87- stores of the output feature group. Defaults to None.
85+ target_stores (Optional[list[str]], optional): A list containing at least one
86+ of 'OnlineStore' or 'OfflineStore'. If unspecified, data will be ingested to the
87+ enabled stores of the output feature group. Defaults to None.
8888 parameters (Optional[Dict[str, Union[str, Dict]]], optional): Parameters to be provided to
8989 the decorated function, available as the 'params' argument. Useful for parameterized
9090 functions. The params argument also contains the set of system provided parameters
@@ -96,6 +96,7 @@ def transform(input_feature_group, input_csv):
9696 development phase to ensure that data is not used until the function is ready. It also
9797 useful for users that want to manage their own data ingestion. Defaults to True.
9898 spark_config (Dict[str, str]): A dict contains the key-value paris for Spark configurations.
99+
99100 Raises:
100101 IngestionError: If any rows are not ingested successfully then a sample of the records,
101102 with failure reasons, is logged.
0 commit comments