feast.diff package

Submodules

feast.diff.infra_diff module

class feast.diff.infra_diff.InfraDiff[source]

Bases: object

infra_object_diffs: List[InfraObjectDiff]
to_string()[source]
update()[source]

Apply the infrastructure changes specified in this object.

class feast.diff.infra_diff.InfraObjectDiff(*args, **kwds)[source]

Bases: Generic[InfraObjectProto]

current_infra_object: InfraObjectProto
infra_object_property_diffs: List[PropertyDiff]
infra_object_type: str
name: str
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.infra_diff.get_infra_object_protos_by_type(infra_proto: Infra, infra_object_class_type: str) List[InfraObjectProto][source]
feast.diff.infra_diff.tag_infra_proto_objects_for_keep_delete_add(existing_objs: Iterable[InfraObjectProto], desired_objs: Iterable[InfraObjectProto]) Tuple[Iterable[InfraObjectProto], Iterable[InfraObjectProto], Iterable[InfraObjectProto]][source]

feast.diff.property_diff module

class feast.diff.property_diff.PropertyDiff(property_name: str, val_existing: str, val_declared: str)[source]

Bases: object

property_name: str
val_declared: str
val_existing: str
class feast.diff.property_diff.TransitionType(value)[source]

Bases: Enum

An enumeration.

CREATE = 1
DELETE = 2
UNCHANGED = 4
UNKNOWN = 0
UPDATE = 3

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
name: str
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]
to_string()[source]
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]

Module contents