Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion generation_config.yaml
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
gapic_generator_version: 2.66.1
googleapis_commitish: 39bd091b055e331a4917143355ab7afa83b7130c
googleapis_commitish: 725496d32a359a40dd773995d3fda0342b440e15
libraries_bom_version: 26.75.0
libraries:
- api_shortname: accessapproval
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -122,6 +122,7 @@ public void createScheduleTest() throws Exception {
.setLastPauseTime(Timestamp.newBuilder().build())
.setLastResumeTime(Timestamp.newBuilder().build())
.setMaxConcurrentRunCount(-1478623794)
.setMaxConcurrentActiveRunCount(-2066355825)
.setAllowQueueing(true)
.setCatchUp(true)
.setLastScheduledRunResponse(Schedule.RunResponse.newBuilder().build())
Expand Down Expand Up @@ -177,6 +178,7 @@ public void createScheduleTest2() throws Exception {
.setLastPauseTime(Timestamp.newBuilder().build())
.setLastResumeTime(Timestamp.newBuilder().build())
.setMaxConcurrentRunCount(-1478623794)
.setMaxConcurrentActiveRunCount(-2066355825)
.setAllowQueueing(true)
.setCatchUp(true)
.setLastScheduledRunResponse(Schedule.RunResponse.newBuilder().build())
Expand Down Expand Up @@ -316,6 +318,7 @@ public void getScheduleTest() throws Exception {
.setLastPauseTime(Timestamp.newBuilder().build())
.setLastResumeTime(Timestamp.newBuilder().build())
.setMaxConcurrentRunCount(-1478623794)
.setMaxConcurrentActiveRunCount(-2066355825)
.setAllowQueueing(true)
.setCatchUp(true)
.setLastScheduledRunResponse(Schedule.RunResponse.newBuilder().build())
Expand Down Expand Up @@ -368,6 +371,7 @@ public void getScheduleTest2() throws Exception {
.setLastPauseTime(Timestamp.newBuilder().build())
.setLastResumeTime(Timestamp.newBuilder().build())
.setMaxConcurrentRunCount(-1478623794)
.setMaxConcurrentActiveRunCount(-2066355825)
.setAllowQueueing(true)
.setCatchUp(true)
.setLastScheduledRunResponse(Schedule.RunResponse.newBuilder().build())
Expand Down Expand Up @@ -718,6 +722,7 @@ public void updateScheduleTest() throws Exception {
.setLastPauseTime(Timestamp.newBuilder().build())
.setLastResumeTime(Timestamp.newBuilder().build())
.setMaxConcurrentRunCount(-1478623794)
.setMaxConcurrentActiveRunCount(-2066355825)
.setAllowQueueing(true)
.setCatchUp(true)
.setLastScheduledRunResponse(Schedule.RunResponse.newBuilder().build())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2230,6 +2230,30 @@ public long getMaxConcurrentRunCount() {
return maxConcurrentRunCount_;
}

public static final int MAX_CONCURRENT_ACTIVE_RUN_COUNT_FIELD_NUMBER = 21;
private long maxConcurrentActiveRunCount_ = 0L;

/**
*
*
* <pre>
* Optional. Specifies the maximum number of active runs that can be executed
* concurrently for this Schedule. This limits the number of runs that can be
* in a non-terminal state at the same time.
* Currently, this field is only supported for requests of type
* CreatePipelineJobRequest.
* </pre>
*
* <code>int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
* </code>
*
* @return The maxConcurrentActiveRunCount.
*/
@java.lang.Override
public long getMaxConcurrentActiveRunCount() {
return maxConcurrentActiveRunCount_;
}

public static final int ALLOW_QUEUEING_FIELD_NUMBER = 12;
private boolean allowQueueing_ = false;

Expand Down Expand Up @@ -2419,6 +2443,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
output.writeMessage(
20, (com.google.cloud.aiplatform.v1beta1.CreateNotebookExecutionJobRequest) request_);
}
if (maxConcurrentActiveRunCount_ != 0L) {
output.writeInt64(21, maxConcurrentActiveRunCount_);
}
getUnknownFields().writeTo(output);
}

Expand Down Expand Up @@ -2497,6 +2524,10 @@ public int getSerializedSize() {
com.google.protobuf.CodedOutputStream.computeMessageSize(
20, (com.google.cloud.aiplatform.v1beta1.CreateNotebookExecutionJobRequest) request_);
}
if (maxConcurrentActiveRunCount_ != 0L) {
size +=
com.google.protobuf.CodedOutputStream.computeInt64Size(21, maxConcurrentActiveRunCount_);
}
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
Expand Down Expand Up @@ -2547,6 +2578,7 @@ public boolean equals(final java.lang.Object obj) {
if (!getLastResumeTime().equals(other.getLastResumeTime())) return false;
}
if (getMaxConcurrentRunCount() != other.getMaxConcurrentRunCount()) return false;
if (getMaxConcurrentActiveRunCount() != other.getMaxConcurrentActiveRunCount()) return false;
if (getAllowQueueing() != other.getAllowQueueing()) return false;
if (getCatchUp() != other.getCatchUp()) return false;
if (hasLastScheduledRunResponse() != other.hasLastScheduledRunResponse()) return false;
Expand Down Expand Up @@ -2629,6 +2661,8 @@ public int hashCode() {
}
hash = (37 * hash) + MAX_CONCURRENT_RUN_COUNT_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashLong(getMaxConcurrentRunCount());
hash = (37 * hash) + MAX_CONCURRENT_ACTIVE_RUN_COUNT_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashLong(getMaxConcurrentActiveRunCount());
hash = (37 * hash) + ALLOW_QUEUEING_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(getAllowQueueing());
hash = (37 * hash) + CATCH_UP_FIELD_NUMBER;
Expand Down Expand Up @@ -2868,6 +2902,7 @@ public Builder clear() {
lastResumeTimeBuilder_ = null;
}
maxConcurrentRunCount_ = 0L;
maxConcurrentActiveRunCount_ = 0L;
allowQueueing_ = false;
catchUp_ = false;
lastScheduledRunResponse_ = null;
Expand Down Expand Up @@ -2967,12 +3002,15 @@ private void buildPartial0(com.google.cloud.aiplatform.v1beta1.Schedule result)
result.maxConcurrentRunCount_ = maxConcurrentRunCount_;
}
if (((from_bitField0_ & 0x00020000) != 0)) {
result.allowQueueing_ = allowQueueing_;
result.maxConcurrentActiveRunCount_ = maxConcurrentActiveRunCount_;
}
if (((from_bitField0_ & 0x00040000) != 0)) {
result.catchUp_ = catchUp_;
result.allowQueueing_ = allowQueueing_;
}
if (((from_bitField0_ & 0x00080000) != 0)) {
result.catchUp_ = catchUp_;
}
if (((from_bitField0_ & 0x00100000) != 0)) {
result.lastScheduledRunResponse_ =
lastScheduledRunResponseBuilder_ == null
? lastScheduledRunResponse_
Expand Down Expand Up @@ -3053,6 +3091,9 @@ public Builder mergeFrom(com.google.cloud.aiplatform.v1beta1.Schedule other) {
if (other.getMaxConcurrentRunCount() != 0L) {
setMaxConcurrentRunCount(other.getMaxConcurrentRunCount());
}
if (other.getMaxConcurrentActiveRunCount() != 0L) {
setMaxConcurrentActiveRunCount(other.getMaxConcurrentActiveRunCount());
}
if (other.getAllowQueueing() != false) {
setAllowQueueing(other.getAllowQueueing());
}
Expand Down Expand Up @@ -3197,13 +3238,13 @@ public Builder mergeFrom(
case 96:
{
allowQueueing_ = input.readBool();
bitField0_ |= 0x00020000;
bitField0_ |= 0x00040000;
break;
} // case 96
case 104:
{
catchUp_ = input.readBool();
bitField0_ |= 0x00040000;
bitField0_ |= 0x00080000;
break;
} // case 104
case 114:
Expand Down Expand Up @@ -3239,7 +3280,7 @@ public Builder mergeFrom(
input.readMessage(
internalGetLastScheduledRunResponseFieldBuilder().getBuilder(),
extensionRegistry);
bitField0_ |= 0x00080000;
bitField0_ |= 0x00100000;
break;
} // case 146
case 154:
Expand All @@ -3257,6 +3298,12 @@ public Builder mergeFrom(
requestCase_ = 20;
break;
} // case 162
case 168:
{
maxConcurrentActiveRunCount_ = input.readInt64();
bitField0_ |= 0x00020000;
break;
} // case 168
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
Expand Down Expand Up @@ -6338,6 +6385,77 @@ public Builder clearMaxConcurrentRunCount() {
return this;
}

private long maxConcurrentActiveRunCount_;

/**
*
*
* <pre>
* Optional. Specifies the maximum number of active runs that can be executed
* concurrently for this Schedule. This limits the number of runs that can be
* in a non-terminal state at the same time.
* Currently, this field is only supported for requests of type
* CreatePipelineJobRequest.
* </pre>
*
* <code>int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
* </code>
*
* @return The maxConcurrentActiveRunCount.
*/
@java.lang.Override
public long getMaxConcurrentActiveRunCount() {
return maxConcurrentActiveRunCount_;
}

/**
*
*
* <pre>
* Optional. Specifies the maximum number of active runs that can be executed
* concurrently for this Schedule. This limits the number of runs that can be
* in a non-terminal state at the same time.
* Currently, this field is only supported for requests of type
* CreatePipelineJobRequest.
* </pre>
*
* <code>int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
* </code>
*
* @param value The maxConcurrentActiveRunCount to set.
* @return This builder for chaining.
*/
public Builder setMaxConcurrentActiveRunCount(long value) {

maxConcurrentActiveRunCount_ = value;
bitField0_ |= 0x00020000;
onChanged();
return this;
}

/**
*
*
* <pre>
* Optional. Specifies the maximum number of active runs that can be executed
* concurrently for this Schedule. This limits the number of runs that can be
* in a non-terminal state at the same time.
* Currently, this field is only supported for requests of type
* CreatePipelineJobRequest.
* </pre>
*
* <code>int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
* </code>
*
* @return This builder for chaining.
*/
public Builder clearMaxConcurrentActiveRunCount() {
bitField0_ = (bitField0_ & ~0x00020000);
maxConcurrentActiveRunCount_ = 0L;
onChanged();
return this;
}

private boolean allowQueueing_;

/**
Expand Down Expand Up @@ -6375,7 +6493,7 @@ public boolean getAllowQueueing() {
public Builder setAllowQueueing(boolean value) {

allowQueueing_ = value;
bitField0_ |= 0x00020000;
bitField0_ |= 0x00040000;
onChanged();
return this;
}
Expand All @@ -6394,7 +6512,7 @@ public Builder setAllowQueueing(boolean value) {
* @return This builder for chaining.
*/
public Builder clearAllowQueueing() {
bitField0_ = (bitField0_ & ~0x00020000);
bitField0_ = (bitField0_ & ~0x00040000);
allowQueueing_ = false;
onChanged();
return this;
Expand Down Expand Up @@ -6437,7 +6555,7 @@ public boolean getCatchUp() {
public Builder setCatchUp(boolean value) {

catchUp_ = value;
bitField0_ |= 0x00040000;
bitField0_ |= 0x00080000;
onChanged();
return this;
}
Expand All @@ -6456,7 +6574,7 @@ public Builder setCatchUp(boolean value) {
* @return This builder for chaining.
*/
public Builder clearCatchUp() {
bitField0_ = (bitField0_ & ~0x00040000);
bitField0_ = (bitField0_ & ~0x00080000);
catchUp_ = false;
onChanged();
return this;
Expand Down Expand Up @@ -6486,7 +6604,7 @@ public Builder clearCatchUp() {
* @return Whether the lastScheduledRunResponse field is set.
*/
public boolean hasLastScheduledRunResponse() {
return ((bitField0_ & 0x00080000) != 0);
return ((bitField0_ & 0x00100000) != 0);
}

/**
Expand Down Expand Up @@ -6539,7 +6657,7 @@ public Builder setLastScheduledRunResponse(
} else {
lastScheduledRunResponseBuilder_.setMessage(value);
}
bitField0_ |= 0x00080000;
bitField0_ |= 0x00100000;
onChanged();
return this;
}
Expand All @@ -6565,7 +6683,7 @@ public Builder setLastScheduledRunResponse(
} else {
lastScheduledRunResponseBuilder_.setMessage(builderForValue.build());
}
bitField0_ |= 0x00080000;
bitField0_ |= 0x00100000;
onChanged();
return this;
}
Expand All @@ -6587,7 +6705,7 @@ public Builder setLastScheduledRunResponse(
public Builder mergeLastScheduledRunResponse(
com.google.cloud.aiplatform.v1beta1.Schedule.RunResponse value) {
if (lastScheduledRunResponseBuilder_ == null) {
if (((bitField0_ & 0x00080000) != 0)
if (((bitField0_ & 0x00100000) != 0)
&& lastScheduledRunResponse_ != null
&& lastScheduledRunResponse_
!= com.google.cloud.aiplatform.v1beta1.Schedule.RunResponse.getDefaultInstance()) {
Expand All @@ -6599,7 +6717,7 @@ public Builder mergeLastScheduledRunResponse(
lastScheduledRunResponseBuilder_.mergeFrom(value);
}
if (lastScheduledRunResponse_ != null) {
bitField0_ |= 0x00080000;
bitField0_ |= 0x00100000;
onChanged();
}
return this;
Expand All @@ -6620,7 +6738,7 @@ public Builder mergeLastScheduledRunResponse(
* </code>
*/
public Builder clearLastScheduledRunResponse() {
bitField0_ = (bitField0_ & ~0x00080000);
bitField0_ = (bitField0_ & ~0x00100000);
lastScheduledRunResponse_ = null;
if (lastScheduledRunResponseBuilder_ != null) {
lastScheduledRunResponseBuilder_.dispose();
Expand All @@ -6646,7 +6764,7 @@ public Builder clearLastScheduledRunResponse() {
*/
public com.google.cloud.aiplatform.v1beta1.Schedule.RunResponse.Builder
getLastScheduledRunResponseBuilder() {
bitField0_ |= 0x00080000;
bitField0_ |= 0x00100000;
onChanged();
return internalGetLastScheduledRunResponseFieldBuilder().getBuilder();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -677,6 +677,24 @@ public interface ScheduleOrBuilder
*/
long getMaxConcurrentRunCount();

/**
*
*
* <pre>
* Optional. Specifies the maximum number of active runs that can be executed
* concurrently for this Schedule. This limits the number of runs that can be
* in a non-terminal state at the same time.
* Currently, this field is only supported for requests of type
* CreatePipelineJobRequest.
* </pre>
*
* <code>int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
* </code>
*
* @return The maxConcurrentActiveRunCount.
*/
long getMaxConcurrentActiveRunCount();

/**
*
*
Expand Down
Loading
Loading