Set created_timestamp and last_updated_timestamp fields

protos/feast/core/OnDemandFeatureView.proto

@@ -55,6 +55,9 @@ message OnDemandFeatureViewSpec {
 message OnDemandFeatureViewMeta {
     // Time where this Feature View is created
     google.protobuf.Timestamp created_timestamp = 1;
+
+    // Time where this Feature View is last updated
+    google.protobuf.Timestamp last_updated_timestamp = 2;
 }
 
 message OnDemandInput {

sdk/python/feast/base_feature_view.py

@@ -28,12 +28,16 @@
 class BaseFeatureView(ABC):
     """A FeatureView defines a logical grouping of features to be served."""
 
+    created_timestamp: Optional[datetime] = None
+    last_updated_timestamp: Optional[datetime] = None
+
     @abstractmethod
     def __init__(self, name: str, features: List[Feature]):
         self._name = name
         self._features = features
         self._projection = FeatureViewProjection.from_definition(self)
         self.created_timestamp: Optional[datetime] = None
+        self.last_updated_timestamp: Optional[datetime] = None
 
     @property
     def name(self) -> str:

sdk/python/feast/feature_view.py

@@ -75,6 +75,7 @@ class FeatureView(BaseFeatureView):
     input: DataSource
     batch_source: DataSource
     stream_source: Optional[DataSource] = None
+    created_timestamp: Optional[datetime] = None
     last_updated_timestamp: Optional[datetime] = None
     materialization_intervals: List[Tuple[datetime, datetime]]
 

sdk/python/feast/on_demand_feature_view.py

@@ -1,7 +1,8 @@
 import copy
 import functools
+from datetime import datetime
 from types import MethodType
-from typing import Dict, List, Type, Union
+from typing import Dict, List, Optional, Type, Union
 
 import dill
 import pandas as pd
@@ -47,6 +48,8 @@ class OnDemandFeatureView(BaseFeatureView):
     input_feature_view_projections: Dict[str, FeatureViewProjection]
     input_request_data_sources: Dict[str, RequestDataSource]
     udf: MethodType
+    created_timestamp: Optional[datetime] = None
+    last_updated_timestamp: Optional[datetime] = None
 
     @log_exceptions
     def __init__(
@@ -71,6 +74,8 @@ def __init__(
                 self.input_feature_view_projections[input_ref] = odfv_input.projection
 
         self.udf = udf
+        self.created_timestamp: Optional[datetime] = None
+        self.last_updated_timestamp: Optional[datetime] = None
 
     @property
     def proto_class(self) -> Type[OnDemandFeatureViewProto]:
@@ -119,6 +124,8 @@ def to_proto(self) -> OnDemandFeatureViewProto:
         meta = OnDemandFeatureViewMeta()
         if self.created_timestamp:
             meta.created_timestamp.FromDatetime(self.created_timestamp)
+        if self.last_updated_timestamp:
+            meta.last_updated_timestamp.FromDatetime(self.last_updated_timestamp)
         inputs = {}
         for input_ref, fv_projection in self.input_feature_view_projections.items():
             inputs[input_ref] = OnDemandInput(
@@ -194,6 +201,10 @@ def from_proto(cls, on_demand_feature_view_proto: OnDemandFeatureViewProto):
             on_demand_feature_view_obj.created_timestamp = (
                 on_demand_feature_view_proto.meta.created_timestamp.ToDatetime()
             )
+        if on_demand_feature_view_proto.meta.HasField("last_updated_timestamp"):
+            on_demand_feature_view_obj.last_updated_timestamp = (
+                on_demand_feature_view_proto.meta.last_updated_timestamp.ToDatetime()
+            )
 
         return on_demand_feature_view_obj
 

sdk/python/feast/registry.py

@@ -231,6 +231,12 @@ def apply_entity(self, entity: Entity, project: str, commit: bool = True):
             commit: Whether the change should be persisted immediately
         """
         entity.is_valid()
+
+        now = datetime.utcnow()
+        if not entity.created_timestamp:
+            entity._created_timestamp = now
+        entity._last_updated_timestamp = now
+
         entity_proto = entity.to_proto()
         entity_proto.spec.project = project
         self._prepare_registry_for_changes()
@@ -278,6 +284,11 @@ def apply_feature_service(
             feature_service: A feature service that will be registered
             project: Feast project that this entity belongs to
         """
+        now = datetime.utcnow()
+        if not feature_service.created_timestamp:
+            feature_service.created_timestamp = now
+        feature_service.last_updated_timestamp = now
+
         feature_service_proto = feature_service.to_proto()
         feature_service_proto.spec.project = project
 
@@ -373,8 +384,12 @@ def apply_feature_view(
             commit: Whether the change should be persisted immediately
         """
         feature_view.ensure_valid()
+
+        now = datetime.utcnow()
         if not feature_view.created_timestamp:
-            feature_view.created_timestamp = datetime.now()
+            feature_view.created_timestamp = now
+        feature_view.last_updated_timestamp = now
+
         feature_view_proto = feature_view.to_proto()
         feature_view_proto.spec.project = project
         self._prepare_registry_for_changes()
@@ -498,6 +513,7 @@ def apply_materialization(
                 existing_feature_view.materialization_intervals.append(
                     (start_date, end_date)
                 )
+                existing_feature_view.last_updated_timestamp = datetime.utcnow()
                 feature_view_proto = existing_feature_view.to_proto()
                 feature_view_proto.spec.project = project
                 del self.cached_registry_proto.feature_views[idx]
@@ -686,6 +702,11 @@ def apply_saved_dataset(
             project: Feast project that this dataset belongs to
             commit: Whether the change should be persisted immediately
         """
+        now = datetime.utcnow()
+        if not saved_dataset.created_timestamp:
+            saved_dataset.created_timestamp = now
+        saved_dataset.last_updated_timestamp = now
+
         saved_dataset_proto = saved_dataset.to_proto()
         saved_dataset_proto.spec.project = project
         self._prepare_registry_for_changes()