feast.diff package
Submodules
feast.diff.infra_diff module
- class feast.diff.infra_diff.InfraDiff[source]
Bases:
object
- infra_object_diffs: List[InfraObjectDiff]
- class feast.diff.infra_diff.InfraObjectDiff(*args, **kwds)[source]
Bases:
Generic
[InfraObjectProto
]- current_infra_object: InfraObjectProto
- infra_object_property_diffs: List[PropertyDiff]
- new_infra_object: InfraObjectProto
- transition_type: TransitionType
- feast.diff.infra_diff.diff_between(current: InfraObjectProto, new: InfraObjectProto, infra_object_type: str) InfraObjectDiff [source]
- feast.diff.infra_diff.diff_infra_protos(current_infra_proto: Infra, new_infra_proto: Infra) InfraDiff [source]
feast.diff.property_diff module
feast.diff.registry_diff module
- class feast.diff.registry_diff.FeastObjectDiff(name: str, feast_object_type: feast.infra.registry.registry.FeastObjectType, current_feast_object: feast.feature_view.FeatureView | feast.on_demand_feature_view.OnDemandFeatureView | feast.request_feature_view.RequestFeatureView | feast.batch_feature_view.BatchFeatureView | feast.stream_feature_view.StreamFeatureView | feast.entity.Entity | feast.feature_service.FeatureService | feast.data_source.DataSource | feast.saved_dataset.ValidationReference | NoneType, new_feast_object: feast.feature_view.FeatureView | feast.on_demand_feature_view.OnDemandFeatureView | feast.request_feature_view.RequestFeatureView | feast.batch_feature_view.BatchFeatureView | feast.stream_feature_view.StreamFeatureView | feast.entity.Entity | feast.feature_service.FeatureService | feast.data_source.DataSource | feast.saved_dataset.ValidationReference | NoneType, feast_object_property_diffs: List[feast.diff.property_diff.PropertyDiff], transition_type: feast.diff.property_diff.TransitionType)[source]
Bases:
object
- current_feast_object: FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference | None
- feast_object_property_diffs: List[PropertyDiff]
- feast_object_type: FeastObjectType
- new_feast_object: FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference | None
- transition_type: TransitionType
- class feast.diff.registry_diff.RegistryDiff[source]
Bases:
object
- add_feast_object_diff(feast_object_diff: FeastObjectDiff)[source]
- feast_object_diffs: List[FeastObjectDiff]
- feast.diff.registry_diff.apply_diff_to_registry(registry: BaseRegistry, registry_diff: RegistryDiff, project: str, commit: bool = True)[source]
Applies the given diff to the given Feast project in the registry.
- Parameters:
registry – The registry to be updated.
registry_diff – The diff to apply.
project – Feast project to be updated.
commit – Whether the change should be persisted immediately
- feast.diff.registry_diff.diff_between(registry: BaseRegistry, current_project: str, desired_repo_contents: RepoContents) RegistryDiff [source]
Returns the difference between the current and desired repo states.
- Parameters:
registry – The registry storing the current repo state.
current_project – The Feast project for which the diff is being computed.
desired_repo_contents – The desired repo state.
- feast.diff.registry_diff.diff_registry_objects(current: FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference, new: FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference, object_type: FeastObjectType) FeastObjectDiff [source]
- feast.diff.registry_diff.extract_objects_for_keep_delete_update_add(registry: BaseRegistry, current_project: str, desired_repo_contents: RepoContents) Tuple[Dict[FeastObjectType, Set[FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference]], Dict[FeastObjectType, Set[FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference]], Dict[FeastObjectType, Set[FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference]], Dict[FeastObjectType, Set[FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference]]] [source]
Returns the objects in the registry that must be modified to achieve the desired repo state.
- Parameters:
registry – The registry storing the current repo state.
current_project – The Feast project whose objects should be compared.
desired_repo_contents – The desired repo state.
- feast.diff.registry_diff.tag_objects_for_keep_delete_update_add(existing_objs: Iterable[FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference], desired_objs: Iterable[FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference]) Tuple[Set[FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference], Set[FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference], Set[FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference], Set[FeatureView | OnDemandFeatureView | RequestFeatureView | BatchFeatureView | StreamFeatureView | Entity | FeatureService | DataSource | ValidationReference]] [source]