diff --git a/flyteidl/gen/pb-go/flyteidl/datacatalog/datacatalog.pb.go b/flyteidl/gen/pb-go/flyteidl/datacatalog/datacatalog.pb.go
index 5e897b2a0b..a643383127 100644
--- a/flyteidl/gen/pb-go/flyteidl/datacatalog/datacatalog.pb.go
+++ b/flyteidl/gen/pb-go/flyteidl/datacatalog/datacatalog.pb.go
@@ -894,11 +894,13 @@ func (m *UpdateArtifactResponse) GetArtifactId() string {
//
// ReservationID message that is composed of several string fields.
type ReservationID struct {
- DatasetId *DatasetID `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
- TagName string `protobuf:"bytes,2,opt,name=tag_name,json=tagName,proto3" json:"tag_name,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ // The unique ID for the reserved dataset
+ DatasetId *DatasetID `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
+ // The specific artifact tag for the reservation
+ TagName string `protobuf:"bytes,2,opt,name=tag_name,json=tagName,proto3" json:"tag_name,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
func (m *ReservationID) Reset() { *m = ReservationID{} }
@@ -942,8 +944,11 @@ func (m *ReservationID) GetTagName() string {
// Try to acquire or extend an artifact reservation. If an active reservation exists, retreive that instance.
type GetOrExtendReservationRequest struct {
- ReservationId *ReservationID `protobuf:"bytes,1,opt,name=reservation_id,json=reservationId,proto3" json:"reservation_id,omitempty"`
- OwnerId string `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
+ // The unique ID for the reservation
+ ReservationId *ReservationID `protobuf:"bytes,1,opt,name=reservation_id,json=reservationId,proto3" json:"reservation_id,omitempty"`
+ // The unique ID of the owner for the reservation
+ OwnerId string `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
+ // Requested reservation extension heartbeat interval
HeartbeatInterval *duration.Duration `protobuf:"bytes,3,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
@@ -998,14 +1003,19 @@ func (m *GetOrExtendReservationRequest) GetHeartbeatInterval() *duration.Duratio
// A reservation including owner, heartbeat interval, expiration timestamp, and various metadata.
type Reservation struct {
- ReservationId *ReservationID `protobuf:"bytes,1,opt,name=reservation_id,json=reservationId,proto3" json:"reservation_id,omitempty"`
- OwnerId string `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
- HeartbeatInterval *duration.Duration `protobuf:"bytes,3,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
- ExpiresAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
- Metadata *Metadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ // The unique ID for the reservation
+ ReservationId *ReservationID `protobuf:"bytes,1,opt,name=reservation_id,json=reservationId,proto3" json:"reservation_id,omitempty"`
+ // The unique ID of the owner for the reservation
+ OwnerId string `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
+ // Recommended heartbeat interval to extend reservation
+ HeartbeatInterval *duration.Duration `protobuf:"bytes,3,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
+ // Expiration timestamp of this reservation
+ ExpiresAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
+ // Free-form metadata associated with the artifact
+ Metadata *Metadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
func (m *Reservation) Reset() { *m = Reservation{} }
@@ -1070,6 +1080,7 @@ func (m *Reservation) GetMetadata() *Metadata {
// Response including either a newly minted reservation or the existing reservation
type GetOrExtendReservationResponse struct {
+ // The reservation to be acquired or extended
Reservation *Reservation `protobuf:"bytes,1,opt,name=reservation,proto3" json:"reservation,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
@@ -1110,11 +1121,13 @@ func (m *GetOrExtendReservationResponse) GetReservation() *Reservation {
// Request to release reservation
type ReleaseReservationRequest struct {
- ReservationId *ReservationID `protobuf:"bytes,1,opt,name=reservation_id,json=reservationId,proto3" json:"reservation_id,omitempty"`
- OwnerId string `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ // The unique ID for the reservation
+ ReservationId *ReservationID `protobuf:"bytes,1,opt,name=reservation_id,json=reservationId,proto3" json:"reservation_id,omitempty"`
+ // The unique ID of the owner for the reservation
+ OwnerId string `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
func (m *ReleaseReservationRequest) Reset() { *m = ReleaseReservationRequest{} }
diff --git a/flyteidl/gen/pb-java/datacatalog/Datacatalog.java b/flyteidl/gen/pb-java/datacatalog/Datacatalog.java
index 1a221b1005..a10dd9b2a4 100644
--- a/flyteidl/gen/pb-java/datacatalog/Datacatalog.java
+++ b/flyteidl/gen/pb-java/datacatalog/Datacatalog.java
@@ -12419,23 +12419,43 @@ public interface ReservationIDOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
boolean hasDatasetId();
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
datacatalog.Datacatalog.DatasetID getDatasetId();
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
datacatalog.Datacatalog.DatasetIDOrBuilder getDatasetIdOrBuilder();
/**
+ *
+ * The specific artifact tag for the reservation
+ *
+ *
* string tag_name = 2;
*/
java.lang.String getTagName();
/**
+ *
+ * The specific artifact tag for the reservation
+ *
+ *
* string tag_name = 2;
*/
com.google.protobuf.ByteString
@@ -12539,18 +12559,30 @@ private ReservationID(
public static final int DATASET_ID_FIELD_NUMBER = 1;
private datacatalog.Datacatalog.DatasetID datasetId_;
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
public boolean hasDatasetId() {
return datasetId_ != null;
}
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
public datacatalog.Datacatalog.DatasetID getDatasetId() {
return datasetId_ == null ? datacatalog.Datacatalog.DatasetID.getDefaultInstance() : datasetId_;
}
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
public datacatalog.Datacatalog.DatasetIDOrBuilder getDatasetIdOrBuilder() {
@@ -12560,6 +12592,10 @@ public datacatalog.Datacatalog.DatasetIDOrBuilder getDatasetIdOrBuilder() {
public static final int TAG_NAME_FIELD_NUMBER = 2;
private volatile java.lang.Object tagName_;
/**
+ *
+ * The specific artifact tag for the reservation
+ *
+ *
* string tag_name = 2;
*/
public java.lang.String getTagName() {
@@ -12575,6 +12611,10 @@ public java.lang.String getTagName() {
}
}
/**
+ *
+ * The specific artifact tag for the reservation
+ *
+ *
* string tag_name = 2;
*/
public com.google.protobuf.ByteString
@@ -12931,12 +12971,20 @@ public Builder mergeFrom(
private com.google.protobuf.SingleFieldBuilderV3<
datacatalog.Datacatalog.DatasetID, datacatalog.Datacatalog.DatasetID.Builder, datacatalog.Datacatalog.DatasetIDOrBuilder> datasetIdBuilder_;
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
public boolean hasDatasetId() {
return datasetIdBuilder_ != null || datasetId_ != null;
}
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
public datacatalog.Datacatalog.DatasetID getDatasetId() {
@@ -12947,6 +12995,10 @@ public datacatalog.Datacatalog.DatasetID getDatasetId() {
}
}
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
public Builder setDatasetId(datacatalog.Datacatalog.DatasetID value) {
@@ -12963,6 +13015,10 @@ public Builder setDatasetId(datacatalog.Datacatalog.DatasetID value) {
return this;
}
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
public Builder setDatasetId(
@@ -12977,6 +13033,10 @@ public Builder setDatasetId(
return this;
}
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
public Builder mergeDatasetId(datacatalog.Datacatalog.DatasetID value) {
@@ -12995,6 +13055,10 @@ public Builder mergeDatasetId(datacatalog.Datacatalog.DatasetID value) {
return this;
}
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
public Builder clearDatasetId() {
@@ -13009,6 +13073,10 @@ public Builder clearDatasetId() {
return this;
}
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
public datacatalog.Datacatalog.DatasetID.Builder getDatasetIdBuilder() {
@@ -13017,6 +13085,10 @@ public datacatalog.Datacatalog.DatasetID.Builder getDatasetIdBuilder() {
return getDatasetIdFieldBuilder().getBuilder();
}
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
public datacatalog.Datacatalog.DatasetIDOrBuilder getDatasetIdOrBuilder() {
@@ -13028,6 +13100,10 @@ public datacatalog.Datacatalog.DatasetIDOrBuilder getDatasetIdOrBuilder() {
}
}
/**
+ *
+ * The unique ID for the reserved dataset
+ *
+ *
* .datacatalog.DatasetID dataset_id = 1;
*/
private com.google.protobuf.SingleFieldBuilderV3<
@@ -13046,6 +13122,10 @@ public datacatalog.Datacatalog.DatasetIDOrBuilder getDatasetIdOrBuilder() {
private java.lang.Object tagName_ = "";
/**
+ *
+ * The specific artifact tag for the reservation
+ *
+ *
* string tag_name = 2;
*/
public java.lang.String getTagName() {
@@ -13061,6 +13141,10 @@ public java.lang.String getTagName() {
}
}
/**
+ *
+ * The specific artifact tag for the reservation
+ *
+ *
* string tag_name = 2;
*/
public com.google.protobuf.ByteString
@@ -13077,6 +13161,10 @@ public java.lang.String getTagName() {
}
}
/**
+ *
+ * The specific artifact tag for the reservation
+ *
+ *
* string tag_name = 2;
*/
public Builder setTagName(
@@ -13090,6 +13178,10 @@ public Builder setTagName(
return this;
}
/**
+ *
+ * The specific artifact tag for the reservation
+ *
+ *
* string tag_name = 2;
*/
public Builder clearTagName() {
@@ -13099,6 +13191,10 @@ public Builder clearTagName() {
return this;
}
/**
+ *
+ * The specific artifact tag for the reservation
+ *
+ *
* string tag_name = 2;
*/
public Builder setTagNameBytes(
@@ -13170,23 +13266,43 @@ public interface GetOrExtendReservationRequestOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
boolean hasReservationId();
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
datacatalog.Datacatalog.ReservationID getReservationId();
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder();
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
java.lang.String getOwnerId();
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
com.google.protobuf.ByteString
@@ -13328,18 +13444,30 @@ private GetOrExtendReservationRequest(
public static final int RESERVATION_ID_FIELD_NUMBER = 1;
private datacatalog.Datacatalog.ReservationID reservationId_;
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public boolean hasReservationId() {
return reservationId_ != null;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationID getReservationId() {
return reservationId_ == null ? datacatalog.Datacatalog.ReservationID.getDefaultInstance() : reservationId_;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder() {
@@ -13349,6 +13477,10 @@ public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder(
public static final int OWNER_ID_FIELD_NUMBER = 2;
private volatile java.lang.Object ownerId_;
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public java.lang.String getOwnerId() {
@@ -13364,6 +13496,10 @@ public java.lang.String getOwnerId() {
}
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public com.google.protobuf.ByteString
@@ -13783,12 +13919,20 @@ public Builder mergeFrom(
private com.google.protobuf.SingleFieldBuilderV3<
datacatalog.Datacatalog.ReservationID, datacatalog.Datacatalog.ReservationID.Builder, datacatalog.Datacatalog.ReservationIDOrBuilder> reservationIdBuilder_;
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public boolean hasReservationId() {
return reservationIdBuilder_ != null || reservationId_ != null;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationID getReservationId() {
@@ -13799,6 +13943,10 @@ public datacatalog.Datacatalog.ReservationID getReservationId() {
}
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public Builder setReservationId(datacatalog.Datacatalog.ReservationID value) {
@@ -13815,6 +13963,10 @@ public Builder setReservationId(datacatalog.Datacatalog.ReservationID value) {
return this;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public Builder setReservationId(
@@ -13829,6 +13981,10 @@ public Builder setReservationId(
return this;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public Builder mergeReservationId(datacatalog.Datacatalog.ReservationID value) {
@@ -13847,6 +14003,10 @@ public Builder mergeReservationId(datacatalog.Datacatalog.ReservationID value) {
return this;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public Builder clearReservationId() {
@@ -13861,6 +14021,10 @@ public Builder clearReservationId() {
return this;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationID.Builder getReservationIdBuilder() {
@@ -13869,6 +14033,10 @@ public datacatalog.Datacatalog.ReservationID.Builder getReservationIdBuilder() {
return getReservationIdFieldBuilder().getBuilder();
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder() {
@@ -13880,6 +14048,10 @@ public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder(
}
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
private com.google.protobuf.SingleFieldBuilderV3<
@@ -13898,6 +14070,10 @@ public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder(
private java.lang.Object ownerId_ = "";
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public java.lang.String getOwnerId() {
@@ -13913,6 +14089,10 @@ public java.lang.String getOwnerId() {
}
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public com.google.protobuf.ByteString
@@ -13929,6 +14109,10 @@ public java.lang.String getOwnerId() {
}
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public Builder setOwnerId(
@@ -13942,6 +14126,10 @@ public Builder setOwnerId(
return this;
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public Builder clearOwnerId() {
@@ -13951,6 +14139,10 @@ public Builder clearOwnerId() {
return this;
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public Builder setOwnerIdBytes(
@@ -14175,23 +14367,43 @@ public interface ReservationOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
boolean hasReservationId();
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
datacatalog.Datacatalog.ReservationID getReservationId();
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder();
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
java.lang.String getOwnerId();
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
com.google.protobuf.ByteString
@@ -14248,14 +14460,26 @@ public interface ReservationOrBuilder extends
com.google.protobuf.TimestampOrBuilder getExpiresAtOrBuilder();
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
boolean hasMetadata();
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
datacatalog.Datacatalog.Metadata getMetadata();
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
datacatalog.Datacatalog.MetadataOrBuilder getMetadataOrBuilder();
@@ -14397,18 +14621,30 @@ private Reservation(
public static final int RESERVATION_ID_FIELD_NUMBER = 1;
private datacatalog.Datacatalog.ReservationID reservationId_;
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public boolean hasReservationId() {
return reservationId_ != null;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationID getReservationId() {
return reservationId_ == null ? datacatalog.Datacatalog.ReservationID.getDefaultInstance() : reservationId_;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder() {
@@ -14418,6 +14654,10 @@ public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder(
public static final int OWNER_ID_FIELD_NUMBER = 2;
private volatile java.lang.Object ownerId_;
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public java.lang.String getOwnerId() {
@@ -14433,6 +14673,10 @@ public java.lang.String getOwnerId() {
}
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public com.google.protobuf.ByteString
@@ -14518,18 +14762,30 @@ public com.google.protobuf.TimestampOrBuilder getExpiresAtOrBuilder() {
public static final int METADATA_FIELD_NUMBER = 6;
private datacatalog.Datacatalog.Metadata metadata_;
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
public boolean hasMetadata() {
return metadata_ != null;
}
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
public datacatalog.Datacatalog.Metadata getMetadata() {
return metadata_ == null ? datacatalog.Datacatalog.Metadata.getDefaultInstance() : metadata_;
}
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
public datacatalog.Datacatalog.MetadataOrBuilder getMetadataOrBuilder() {
@@ -14966,12 +15222,20 @@ public Builder mergeFrom(
private com.google.protobuf.SingleFieldBuilderV3<
datacatalog.Datacatalog.ReservationID, datacatalog.Datacatalog.ReservationID.Builder, datacatalog.Datacatalog.ReservationIDOrBuilder> reservationIdBuilder_;
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public boolean hasReservationId() {
return reservationIdBuilder_ != null || reservationId_ != null;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationID getReservationId() {
@@ -14982,6 +15246,10 @@ public datacatalog.Datacatalog.ReservationID getReservationId() {
}
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public Builder setReservationId(datacatalog.Datacatalog.ReservationID value) {
@@ -14998,6 +15266,10 @@ public Builder setReservationId(datacatalog.Datacatalog.ReservationID value) {
return this;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public Builder setReservationId(
@@ -15012,6 +15284,10 @@ public Builder setReservationId(
return this;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public Builder mergeReservationId(datacatalog.Datacatalog.ReservationID value) {
@@ -15030,6 +15306,10 @@ public Builder mergeReservationId(datacatalog.Datacatalog.ReservationID value) {
return this;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public Builder clearReservationId() {
@@ -15044,6 +15324,10 @@ public Builder clearReservationId() {
return this;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationID.Builder getReservationIdBuilder() {
@@ -15052,6 +15336,10 @@ public datacatalog.Datacatalog.ReservationID.Builder getReservationIdBuilder() {
return getReservationIdFieldBuilder().getBuilder();
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder() {
@@ -15063,6 +15351,10 @@ public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder(
}
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
private com.google.protobuf.SingleFieldBuilderV3<
@@ -15081,6 +15373,10 @@ public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder(
private java.lang.Object ownerId_ = "";
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public java.lang.String getOwnerId() {
@@ -15096,6 +15392,10 @@ public java.lang.String getOwnerId() {
}
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public com.google.protobuf.ByteString
@@ -15112,6 +15412,10 @@ public java.lang.String getOwnerId() {
}
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public Builder setOwnerId(
@@ -15125,6 +15429,10 @@ public Builder setOwnerId(
return this;
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public Builder clearOwnerId() {
@@ -15134,6 +15442,10 @@ public Builder clearOwnerId() {
return this;
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public Builder setOwnerIdBytes(
@@ -15458,12 +15770,20 @@ public com.google.protobuf.TimestampOrBuilder getExpiresAtOrBuilder() {
private com.google.protobuf.SingleFieldBuilderV3<
datacatalog.Datacatalog.Metadata, datacatalog.Datacatalog.Metadata.Builder, datacatalog.Datacatalog.MetadataOrBuilder> metadataBuilder_;
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
public boolean hasMetadata() {
return metadataBuilder_ != null || metadata_ != null;
}
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
public datacatalog.Datacatalog.Metadata getMetadata() {
@@ -15474,6 +15794,10 @@ public datacatalog.Datacatalog.Metadata getMetadata() {
}
}
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
public Builder setMetadata(datacatalog.Datacatalog.Metadata value) {
@@ -15490,6 +15814,10 @@ public Builder setMetadata(datacatalog.Datacatalog.Metadata value) {
return this;
}
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
public Builder setMetadata(
@@ -15504,6 +15832,10 @@ public Builder setMetadata(
return this;
}
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
public Builder mergeMetadata(datacatalog.Datacatalog.Metadata value) {
@@ -15522,6 +15854,10 @@ public Builder mergeMetadata(datacatalog.Datacatalog.Metadata value) {
return this;
}
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
public Builder clearMetadata() {
@@ -15536,6 +15872,10 @@ public Builder clearMetadata() {
return this;
}
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
public datacatalog.Datacatalog.Metadata.Builder getMetadataBuilder() {
@@ -15544,6 +15884,10 @@ public datacatalog.Datacatalog.Metadata.Builder getMetadataBuilder() {
return getMetadataFieldBuilder().getBuilder();
}
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
public datacatalog.Datacatalog.MetadataOrBuilder getMetadataOrBuilder() {
@@ -15555,6 +15899,10 @@ public datacatalog.Datacatalog.MetadataOrBuilder getMetadataOrBuilder() {
}
}
/**
+ *
+ * Free-form metadata associated with the artifact
+ *
+ *
* .datacatalog.Metadata metadata = 6;
*/
private com.google.protobuf.SingleFieldBuilderV3<
@@ -15628,14 +15976,26 @@ public interface GetOrExtendReservationResponseOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
boolean hasReservation();
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
datacatalog.Datacatalog.Reservation getReservation();
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
datacatalog.Datacatalog.ReservationOrBuilder getReservationOrBuilder();
@@ -15731,18 +16091,30 @@ private GetOrExtendReservationResponse(
public static final int RESERVATION_FIELD_NUMBER = 1;
private datacatalog.Datacatalog.Reservation reservation_;
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
public boolean hasReservation() {
return reservation_ != null;
}
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
public datacatalog.Datacatalog.Reservation getReservation() {
return reservation_ == null ? datacatalog.Datacatalog.Reservation.getDefaultInstance() : reservation_;
}
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
public datacatalog.Datacatalog.ReservationOrBuilder getReservationOrBuilder() {
@@ -16072,12 +16444,20 @@ public Builder mergeFrom(
private com.google.protobuf.SingleFieldBuilderV3<
datacatalog.Datacatalog.Reservation, datacatalog.Datacatalog.Reservation.Builder, datacatalog.Datacatalog.ReservationOrBuilder> reservationBuilder_;
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
public boolean hasReservation() {
return reservationBuilder_ != null || reservation_ != null;
}
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
public datacatalog.Datacatalog.Reservation getReservation() {
@@ -16088,6 +16468,10 @@ public datacatalog.Datacatalog.Reservation getReservation() {
}
}
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
public Builder setReservation(datacatalog.Datacatalog.Reservation value) {
@@ -16104,6 +16488,10 @@ public Builder setReservation(datacatalog.Datacatalog.Reservation value) {
return this;
}
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
public Builder setReservation(
@@ -16118,6 +16506,10 @@ public Builder setReservation(
return this;
}
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
public Builder mergeReservation(datacatalog.Datacatalog.Reservation value) {
@@ -16136,6 +16528,10 @@ public Builder mergeReservation(datacatalog.Datacatalog.Reservation value) {
return this;
}
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
public Builder clearReservation() {
@@ -16150,6 +16546,10 @@ public Builder clearReservation() {
return this;
}
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
public datacatalog.Datacatalog.Reservation.Builder getReservationBuilder() {
@@ -16158,6 +16558,10 @@ public datacatalog.Datacatalog.Reservation.Builder getReservationBuilder() {
return getReservationFieldBuilder().getBuilder();
}
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
public datacatalog.Datacatalog.ReservationOrBuilder getReservationOrBuilder() {
@@ -16169,6 +16573,10 @@ public datacatalog.Datacatalog.ReservationOrBuilder getReservationOrBuilder() {
}
}
/**
+ *
+ * The reservation to be acquired or extended
+ *
+ *
* .datacatalog.Reservation reservation = 1;
*/
private com.google.protobuf.SingleFieldBuilderV3<
@@ -16242,23 +16650,43 @@ public interface ReleaseReservationRequestOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
boolean hasReservationId();
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
datacatalog.Datacatalog.ReservationID getReservationId();
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder();
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
java.lang.String getOwnerId();
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
com.google.protobuf.ByteString
@@ -16362,18 +16790,30 @@ private ReleaseReservationRequest(
public static final int RESERVATION_ID_FIELD_NUMBER = 1;
private datacatalog.Datacatalog.ReservationID reservationId_;
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public boolean hasReservationId() {
return reservationId_ != null;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationID getReservationId() {
return reservationId_ == null ? datacatalog.Datacatalog.ReservationID.getDefaultInstance() : reservationId_;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder() {
@@ -16383,6 +16823,10 @@ public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder(
public static final int OWNER_ID_FIELD_NUMBER = 2;
private volatile java.lang.Object ownerId_;
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public java.lang.String getOwnerId() {
@@ -16398,6 +16842,10 @@ public java.lang.String getOwnerId() {
}
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public com.google.protobuf.ByteString
@@ -16754,12 +17202,20 @@ public Builder mergeFrom(
private com.google.protobuf.SingleFieldBuilderV3<
datacatalog.Datacatalog.ReservationID, datacatalog.Datacatalog.ReservationID.Builder, datacatalog.Datacatalog.ReservationIDOrBuilder> reservationIdBuilder_;
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public boolean hasReservationId() {
return reservationIdBuilder_ != null || reservationId_ != null;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationID getReservationId() {
@@ -16770,6 +17226,10 @@ public datacatalog.Datacatalog.ReservationID getReservationId() {
}
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public Builder setReservationId(datacatalog.Datacatalog.ReservationID value) {
@@ -16786,6 +17246,10 @@ public Builder setReservationId(datacatalog.Datacatalog.ReservationID value) {
return this;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public Builder setReservationId(
@@ -16800,6 +17264,10 @@ public Builder setReservationId(
return this;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public Builder mergeReservationId(datacatalog.Datacatalog.ReservationID value) {
@@ -16818,6 +17286,10 @@ public Builder mergeReservationId(datacatalog.Datacatalog.ReservationID value) {
return this;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public Builder clearReservationId() {
@@ -16832,6 +17304,10 @@ public Builder clearReservationId() {
return this;
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationID.Builder getReservationIdBuilder() {
@@ -16840,6 +17316,10 @@ public datacatalog.Datacatalog.ReservationID.Builder getReservationIdBuilder() {
return getReservationIdFieldBuilder().getBuilder();
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder() {
@@ -16851,6 +17331,10 @@ public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder(
}
}
/**
+ *
+ * The unique ID for the reservation
+ *
+ *
* .datacatalog.ReservationID reservation_id = 1;
*/
private com.google.protobuf.SingleFieldBuilderV3<
@@ -16869,6 +17353,10 @@ public datacatalog.Datacatalog.ReservationIDOrBuilder getReservationIdOrBuilder(
private java.lang.Object ownerId_ = "";
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public java.lang.String getOwnerId() {
@@ -16884,6 +17372,10 @@ public java.lang.String getOwnerId() {
}
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public com.google.protobuf.ByteString
@@ -16900,6 +17392,10 @@ public java.lang.String getOwnerId() {
}
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public Builder setOwnerId(
@@ -16913,6 +17409,10 @@ public Builder setOwnerId(
return this;
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public Builder clearOwnerId() {
@@ -16922,6 +17422,10 @@ public Builder clearOwnerId() {
return this;
}
/**
+ *
+ * The unique ID of the owner for the reservation
+ *
+ *
* string owner_id = 2;
*/
public Builder setOwnerIdBytes(
diff --git a/flyteidl/protos/flyteidl/datacatalog/datacatalog.proto b/flyteidl/protos/flyteidl/datacatalog/datacatalog.proto
index b308ac647b..6f059159f3 100644
--- a/flyteidl/protos/flyteidl/datacatalog/datacatalog.proto
+++ b/flyteidl/protos/flyteidl/datacatalog/datacatalog.proto
@@ -203,34 +203,55 @@ message UpdateArtifactResponse {
* ReservationID message that is composed of several string fields.
*/
message ReservationID {
+ // The unique ID for the reserved dataset
DatasetID dataset_id = 1;
+
+ // The specific artifact tag for the reservation
string tag_name = 2;
}
// Try to acquire or extend an artifact reservation. If an active reservation exists, retreive that instance.
message GetOrExtendReservationRequest {
+ // The unique ID for the reservation
ReservationID reservation_id = 1;
+
+ // The unique ID of the owner for the reservation
string owner_id = 2;
- google.protobuf.Duration heartbeat_interval = 3; // Requested reservation extension heartbeat interval
+
+ // Requested reservation extension heartbeat interval
+ google.protobuf.Duration heartbeat_interval = 3;
}
// A reservation including owner, heartbeat interval, expiration timestamp, and various metadata.
message Reservation {
+ // The unique ID for the reservation
ReservationID reservation_id = 1;
+
+ // The unique ID of the owner for the reservation
string owner_id = 2;
- google.protobuf.Duration heartbeat_interval = 3; // Recommended heartbeat interval to extend reservation
- google.protobuf.Timestamp expires_at = 4; // Expiration timestamp of this reservation
+
+ // Recommended heartbeat interval to extend reservation
+ google.protobuf.Duration heartbeat_interval = 3;
+
+ // Expiration timestamp of this reservation
+ google.protobuf.Timestamp expires_at = 4;
+
+ // Free-form metadata associated with the artifact
Metadata metadata = 6;
}
// Response including either a newly minted reservation or the existing reservation
message GetOrExtendReservationResponse {
+ // The reservation to be acquired or extended
Reservation reservation = 1;
}
// Request to release reservation
message ReleaseReservationRequest {
+ // The unique ID for the reservation
ReservationID reservation_id = 1;
+
+ // The unique ID of the owner for the reservation
string owner_id = 2;
}