@@ -404,9 +404,7 @@ def apply_data_source(
404404 return
405405 else :
406406 # Preserve created_timestamp from existing data source
407- data_source .created_timestamp = (
408- existing_data_source .created_timestamp
409- )
407+ data_source .created_timestamp = existing_data_source .created_timestamp
410408 del registry .data_sources [idx ]
411409 break
412410
@@ -694,13 +692,13 @@ def apply_feature_view(
694692
695693 if not is_latest :
696694 # Explicit version: check if it exists (pin/revert) or not (forward declaration).
697- # Note: The file registry is last-write-wins for true concurrent races —
695+ # Note: The file registry is last-write-wins for true concurrent races â
698696 # this is a pre-existing limitation for all file registry operations.
699697 # For multi-client environments, use the SQL registry.
700698 record = self ._get_version_record (feature_view .name , project , pin_version )
701699
702700 if record is not None :
703- # Version exists → pin/revert to that snapshot
701+ # Version exists â pin/revert to that snapshot
704702 # Check that the user hasn't also modified the definition.
705703 # Compare user's FV (with version="latest") against active FV.
706704 self ._prepare_registry_for_changes (project )
@@ -741,7 +739,7 @@ def apply_feature_view(
741739 # Apply the restored FV using the standard path below
742740 feature_view = restored_fv
743741 else :
744- # Version doesn't exist → forward declaration: create it
742+ # Version doesn't exist â forward declaration: create it
745743 feature_view .current_version_number = pin_version
746744 feature_view_proto = feature_view .to_proto ()
747745 feature_view_proto .spec .project = project
0 commit comments