diff --git a/core/src/main/java/feast/core/model/Source.java b/core/src/main/java/feast/core/model/Source.java index 94515629cf..1f2e538209 100644 --- a/core/src/main/java/feast/core/model/Source.java +++ b/core/src/main/java/feast/core/model/Source.java @@ -65,7 +65,9 @@ public Source(SourceType type, KafkaSourceConfig config, boolean isDefault) { */ public static Source fromProto(SourceProto.Source sourceProto) { if (sourceProto.equals(SourceProto.Source.getDefaultInstance())) { - return new Source(); + Source source = new Source(); + source.isDefault = true; + return source; } switch (sourceProto.getType()) { diff --git a/sdk/python/feast/client.py b/sdk/python/feast/client.py index b7568c8581..216783c94b 100644 --- a/sdk/python/feast/client.py +++ b/sdk/python/feast/client.py @@ -219,7 +219,7 @@ def _apply_feature_set(self, feature_set: FeatureSet): feature_set._update_from_feature_set(applied_fs, is_dirty=False) return if apply_fs_response.status == ApplyFeatureSetResponse.Status.NO_CHANGE: - print(f'No change detected in feature set {feature_set.name}:{feature_set.version}') + print(f'No change detected in feature set {feature_set.name}') return except grpc.RpcError as e: print(format_grpc_exception("ApplyFeatureSet", e.code(), e.details()))