Skip to content

Commit 9c2a55f

Browse files
Alexandru OrmenisanAlexandru Ormenisan
Alexandru Ormenisan
authored and
Alexandru Ormenisan
committed
fixes
1 parent b4976ec commit 9c2a55f

File tree

4 files changed

+136
-62
lines changed

4 files changed

+136
-62
lines changed
Loading

docs/user_guides/fs/provenance/provenance.md

+28-62
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,28 @@
1-
# Provenance
1+
# Provenance
22

3-
## Introduction
3+
## Introduction
44

5-
Hopsworks feature store allows users to track provenance (lineage) between storage connectors, feature groups, feature views, training datasets and models. Tracking lineage allows users to determine where/if a feature group is being used. You can track if feature groups are being used to create additional (derived) feature groups or feature views.
5+
Hopsworks allows users to track provenance (lineage) between:
66

7-
You can interact with the provenance graph using the UI and the APIs.
7+
- storage connectors
8+
- feature groups
9+
- feature views
10+
- training datasets
11+
- models
12+
13+
In the provenance pages we will call a provenance artifact or shortly artifact, any of the five entities above.
14+
15+
When following the provenance graph:
16+
17+
```
18+
storage connector -> feature group -> feature group -> feature view -> training dataset -> model
19+
```
20+
21+
we will call the parent, the artifact to the left, and the child, the artifact to the right. So a feature view has a number of feature groups as parents and can have a number of training datasets as children.
22+
23+
Tracking provenance allows users to determine where and if an artifact is being used. You can track, for example, if feature groups are being used to create additional (derived) feature groups or feature views, or if their data is eventually used to train models.
24+
25+
You can interact with the provenance graph using the UI or the APIs.
826

927
## Step 1: Storage connector lineage
1028

@@ -87,7 +105,7 @@ When creating a feature group, it is possible to specify a list of feature group
87105
# Retrieve the feature group
88106
profiles_fg = fs.get_external_feature_group("user_profiles", version=1)
89107

90-
# Do feature engineering
108+
# Do feature engineering
91109
age_df = transaction_df.merge(profiles_fg.read(), on="cc_num", how="left")
92110
transaction_df["age_at_transaction"] = (age_df["datetime"] - age_df["birthdate"]) / np.timedelta64(1, "Y")
93111

@@ -103,7 +121,7 @@ When creating a feature group, it is possible to specify a list of feature group
103121
transaction_fg.insert(transaction_df)
104122
```
105123

106-
Another example use case for derived feature group is if you have a feature group containing features with daily resolution and you are using the content of that feature group to populate a second feature group with monthly resolution:
124+
Another example use case for derived feature group is if you have a feature group containing features with daily resolution and you are using the content of that feature group to populate a second feature group with monthly resolution:
107125

108126
=== "Python"
109127

@@ -112,7 +130,7 @@ Another example use case for derived feature group is if you have a feature grou
112130
daily_transaction_fg = fs.get_feature_group("daily_transaction", version=1)
113131
daily_transaction_df = daily_transaction_fg.read()
114132

115-
# Do feature engineering
133+
# Do feature engineering
116134
cc_group = daily_transaction_df[["cc_num", "amount", "datetime"]] \
117135
.groupby("cc_num") \
118136
.rolling("1M", on="datetime")
@@ -204,10 +222,10 @@ You can also traverse the provenance graph in the opposite direction. Starting f
204222
```python
205223
lineage = transaction_fg.get_generated_feature_views()
206224

207-
# List all accessible downstream feature views
225+
# List all accessible downstream feature views
208226
lineage.accessible
209227

210-
# List all the inaccessible downstream feature views
228+
# List all the inaccessible downstream feature views
211229
lineage.inaccessible
212230
```
213231

@@ -252,7 +270,7 @@ Also we added a utility method to retrieve from the user's accessible models, th
252270
model = fraud_fv.get_newest_model(training_dataset_version: 1)
253271
```
254272

255-
### Using the UI
273+
### Using the UI
256274

257275
In the feature view overview UI you can explore the provenance graph of the feature view:
258276

@@ -262,55 +280,3 @@ In the feature view overview UI you can explore the provenance graph of the feat
262280
<figcaption>Feature view provenance graph</figcaption>
263281
</figure>
264282
</p>
265-
266-
## Step 3: Model lineage
267-
268-
The relationship between feature views and models is captured automatically when you create a model. You can inspect the relationship between feature views and models using the APIs or the UI.
269-
=== "Python"
270-
271-
```python
272-
lineage = model.get_feature_view_provenance()
273-
274-
# List all accessible parent feature views
275-
lineage.accessible
276-
277-
# List all deleted parent feature views
278-
lineage.deleted
279-
280-
# List all the inaccessible parent feature views
281-
lineage.inaccessible
282-
```
283-
284-
You can also retrieve the training dataset provenance object.
285-
=== "Python"
286-
287-
```python
288-
lineage = model.get_training_dataset_provenance()
289-
290-
# List all accessible parent training datasets
291-
lineage.accessible
292-
293-
# List all deleted parent training datasets
294-
lineage.deleted
295-
296-
# List all the inaccessible parent training datasets
297-
lineage.inaccessible
298-
```
299-
300-
You can also retrieve directly the parent feature view object, without the need to extract them from the provenance links object
301-
=== "Python"
302-
303-
```python
304-
feature_view = model.get_feature_view()
305-
```
306-
This utility method also has the options to initialize the required components for batch or online retrieval of feature vectors.
307-
=== "Python"
308-
309-
```python
310-
model.get_feature_view(init: bool = True, online: Optional[bool]: None)
311-
```
312-
313-
By default, the base init for feature vector retrieval is enabled. In case you have a workflow that requires more particular options, you can disable this base init by setting the `init` to `false`.
314-
The method detects if it is running within a deployment and will initialize the feature vector retrieval for the serving.
315-
If the `online` argument is provided and `true` it will initialize for online feature vector retrieval.
316-
If the `online` argument is provided and `false` it will initialize the feature vector retrieval for batch scoring.
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,107 @@
1+
# Provenance
2+
3+
## Introduction
4+
5+
Hopsworks allows users to track provenance (lineage) between:
6+
7+
- storage connectors
8+
- feature groups
9+
- feature views
10+
- training datasets
11+
- models
12+
13+
In the provenance pages we will call a provenance artifact or shortly artifact, any of the five entities above.
14+
15+
When following the provenance graph:
16+
17+
```
18+
storage connector -> feature group -> feature group -> feature view -> training dataset -> model
19+
```
20+
21+
we will call the parent, the artifact to the left, and the child, the artifact to the right. So a feature view has a number of feature groups as parents and can have a number of training datasets as children.
22+
23+
Tracking provenance allows users to determine where and if an artifact is being used. You can track, for example, if feature groups are being used to create additional (derived) feature groups or feature views, or if their data is eventually used to train models.
24+
25+
You can interact with the provenance graph using the UI or the APIs.
26+
27+
## Model provenance
28+
29+
The relationship between feature views and models is captured in the model constructor. If you do not provide at least the feature view object to the constructor, the provenance will not capture this relation and you will not be able to navigate from model to the feature view it used or from the feature view to this model.
30+
31+
You can provide the feature view object and have the training dataset version be inferred.
32+
33+
=== "Python"
34+
35+
```python
36+
# this fv object will be provided to the model constructor
37+
fv = hsfs.get_feature_view(...)
38+
39+
# when calling trainig data related methods on the feature view, the training dataset version is cached in the feature view and is implicitly provided to the model constructor
40+
X_train, X_test, y_train, y_test = feature_view.train_test_split(...)
41+
42+
# provide the feature_view object in the model constructor
43+
hsml.model_registry.ModelRegistry.python.create_model(
44+
...
45+
feature_view = fv
46+
...)
47+
```
48+
49+
You can of course explicitly provide the training dataset version.
50+
=== "Python"
51+
52+
```python
53+
# this object will be provided to the model constructor
54+
fv = hsfs.get_feature_view(...)
55+
56+
# this training dataset version will be provided to the model constructor
57+
X_train, X_test, y_train, y_test = feature_view.get_train_test_split(training_dataset_version=1)
58+
59+
# provide the feature_view object in the model constructor
60+
hsml.model_registry.ModelRegistry.python.create_model(
61+
...
62+
feature_view = fv,
63+
training_dataset_version = 1,
64+
...)
65+
```
66+
67+
Once the relation is stored in the provenance graph, you can navigate the graph from model to feature view or training dataset and the other way around.
68+
69+
From the model page, in the UI, you can view the provenance graph:
70+
71+
<p align="center">
72+
<figure>
73+
<img src="../../../../assets/images/guides/mlops/provenance/provenance_model.png" alt="Model provenance graph">
74+
<figcaption>Provenance graph of derived feature groups</figcaption>
75+
</figure>
76+
</p>
77+
78+
Users can call the `get_feature_view_provenance` or the `get_training_dataset_provenance` methods which will each return a [Link](#provenance-links) object.
79+
80+
You can also retrieve directly the parent feature view object, without the need to extract them from the provenance links object
81+
82+
=== "Python"
83+
84+
```python
85+
feature_view = model.get_feature_view()
86+
```
87+
88+
This utility method also has the options to initialize the required components for batch or online retrieval of feature vectors.
89+
90+
=== "Python"
91+
92+
```python
93+
model.get_feature_view(init: bool = True, online: Optional[bool]: None)
94+
```
95+
96+
By default, the base init for feature vector retrieval is enabled. In case you have a workflow that requires more particular options, you can disable this base init by setting the `init` to `false`.
97+
The method detects if it is running within a deployment and will initialize the feature vector retrieval for the serving.
98+
If the `online` argument is provided and `true` it will initialize for online feature vector retrieval.
99+
If the `online` argument is provided and `false` it will initialize the feature vector retrieval for batch scoring.
100+
101+
## Provenance Links
102+
103+
All the `_provenance` methods return a `Link` dictionary object that contains `accessible`, `inaccesible`, `deleted` lists.
104+
105+
- `accessible` - contains any artifact from the result, that the user has access to.
106+
- `inaccessible` - contains any artifacts that might have been shared at some point in the past, but where this sharing was retracted. Since the relation between artifacts is still maintained in the provenance, the user will only have access to limited metadata and the artifacts will be included in this `inaccessible` list.
107+
- `deleted` - contains artifacts that are deleted with children stil present in the system. There is minimum amount of metadata for the deleted allowing for some limited human readable identification.

mkdocs.yml

+1
Original file line numberDiff line numberDiff line change
@@ -195,6 +195,7 @@ nav:
195195
- API Protocol: user_guides/mlops/serving/api-protocol.md
196196
- Troubleshooting: user_guides/mlops/serving/troubleshooting.md
197197
- Vector Database: user_guides/mlops/vector_database/index.md
198+
- Provenance: user_guides/mlops/provenance/provenance.md
198199
- Migration:
199200
- 3.X to 4.0: user_guides/migration/40_migration.md
200201
- Setup and Administration:

0 commit comments

Comments
 (0)