@@ -2230,6 +2230,30 @@ public long getMaxConcurrentRunCount() {
22302230 return maxConcurrentRunCount_ ;
22312231 }
22322232
2233+ public static final int MAX_CONCURRENT_ACTIVE_RUN_COUNT_FIELD_NUMBER = 21 ;
2234+ private long maxConcurrentActiveRunCount_ = 0L ;
2235+
2236+ /**
2237+ *
2238+ *
2239+ * <pre>
2240+ * Optional. Specifies the maximum number of active runs that can be executed
2241+ * concurrently for this Schedule. This limits the number of runs that can be
2242+ * in a non-terminal state at the same time.
2243+ * Currently, this field is only supported for requests of type
2244+ * CreatePipelineJobRequest.
2245+ * </pre>
2246+ *
2247+ * <code>int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
2248+ * </code>
2249+ *
2250+ * @return The maxConcurrentActiveRunCount.
2251+ */
2252+ @ java .lang .Override
2253+ public long getMaxConcurrentActiveRunCount () {
2254+ return maxConcurrentActiveRunCount_ ;
2255+ }
2256+
22332257 public static final int ALLOW_QUEUEING_FIELD_NUMBER = 12 ;
22342258 private boolean allowQueueing_ = false ;
22352259
@@ -2419,6 +2443,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
24192443 output .writeMessage (
24202444 20 , (com .google .cloud .aiplatform .v1beta1 .CreateNotebookExecutionJobRequest ) request_ );
24212445 }
2446+ if (maxConcurrentActiveRunCount_ != 0L ) {
2447+ output .writeInt64 (21 , maxConcurrentActiveRunCount_ );
2448+ }
24222449 getUnknownFields ().writeTo (output );
24232450 }
24242451
@@ -2497,6 +2524,10 @@ public int getSerializedSize() {
24972524 com .google .protobuf .CodedOutputStream .computeMessageSize (
24982525 20 , (com .google .cloud .aiplatform .v1beta1 .CreateNotebookExecutionJobRequest ) request_ );
24992526 }
2527+ if (maxConcurrentActiveRunCount_ != 0L ) {
2528+ size +=
2529+ com .google .protobuf .CodedOutputStream .computeInt64Size (21 , maxConcurrentActiveRunCount_ );
2530+ }
25002531 size += getUnknownFields ().getSerializedSize ();
25012532 memoizedSize = size ;
25022533 return size ;
@@ -2547,6 +2578,7 @@ public boolean equals(final java.lang.Object obj) {
25472578 if (!getLastResumeTime ().equals (other .getLastResumeTime ())) return false ;
25482579 }
25492580 if (getMaxConcurrentRunCount () != other .getMaxConcurrentRunCount ()) return false ;
2581+ if (getMaxConcurrentActiveRunCount () != other .getMaxConcurrentActiveRunCount ()) return false ;
25502582 if (getAllowQueueing () != other .getAllowQueueing ()) return false ;
25512583 if (getCatchUp () != other .getCatchUp ()) return false ;
25522584 if (hasLastScheduledRunResponse () != other .hasLastScheduledRunResponse ()) return false ;
@@ -2629,6 +2661,8 @@ public int hashCode() {
26292661 }
26302662 hash = (37 * hash ) + MAX_CONCURRENT_RUN_COUNT_FIELD_NUMBER ;
26312663 hash = (53 * hash ) + com .google .protobuf .Internal .hashLong (getMaxConcurrentRunCount ());
2664+ hash = (37 * hash ) + MAX_CONCURRENT_ACTIVE_RUN_COUNT_FIELD_NUMBER ;
2665+ hash = (53 * hash ) + com .google .protobuf .Internal .hashLong (getMaxConcurrentActiveRunCount ());
26322666 hash = (37 * hash ) + ALLOW_QUEUEING_FIELD_NUMBER ;
26332667 hash = (53 * hash ) + com .google .protobuf .Internal .hashBoolean (getAllowQueueing ());
26342668 hash = (37 * hash ) + CATCH_UP_FIELD_NUMBER ;
@@ -2868,6 +2902,7 @@ public Builder clear() {
28682902 lastResumeTimeBuilder_ = null ;
28692903 }
28702904 maxConcurrentRunCount_ = 0L ;
2905+ maxConcurrentActiveRunCount_ = 0L ;
28712906 allowQueueing_ = false ;
28722907 catchUp_ = false ;
28732908 lastScheduledRunResponse_ = null ;
@@ -2967,12 +3002,15 @@ private void buildPartial0(com.google.cloud.aiplatform.v1beta1.Schedule result)
29673002 result .maxConcurrentRunCount_ = maxConcurrentRunCount_ ;
29683003 }
29693004 if (((from_bitField0_ & 0x00020000 ) != 0 )) {
2970- result .allowQueueing_ = allowQueueing_ ;
3005+ result .maxConcurrentActiveRunCount_ = maxConcurrentActiveRunCount_ ;
29713006 }
29723007 if (((from_bitField0_ & 0x00040000 ) != 0 )) {
2973- result .catchUp_ = catchUp_ ;
3008+ result .allowQueueing_ = allowQueueing_ ;
29743009 }
29753010 if (((from_bitField0_ & 0x00080000 ) != 0 )) {
3011+ result .catchUp_ = catchUp_ ;
3012+ }
3013+ if (((from_bitField0_ & 0x00100000 ) != 0 )) {
29763014 result .lastScheduledRunResponse_ =
29773015 lastScheduledRunResponseBuilder_ == null
29783016 ? lastScheduledRunResponse_
@@ -3053,6 +3091,9 @@ public Builder mergeFrom(com.google.cloud.aiplatform.v1beta1.Schedule other) {
30533091 if (other .getMaxConcurrentRunCount () != 0L ) {
30543092 setMaxConcurrentRunCount (other .getMaxConcurrentRunCount ());
30553093 }
3094+ if (other .getMaxConcurrentActiveRunCount () != 0L ) {
3095+ setMaxConcurrentActiveRunCount (other .getMaxConcurrentActiveRunCount ());
3096+ }
30563097 if (other .getAllowQueueing () != false ) {
30573098 setAllowQueueing (other .getAllowQueueing ());
30583099 }
@@ -3197,13 +3238,13 @@ public Builder mergeFrom(
31973238 case 96 :
31983239 {
31993240 allowQueueing_ = input .readBool ();
3200- bitField0_ |= 0x00020000 ;
3241+ bitField0_ |= 0x00040000 ;
32013242 break ;
32023243 } // case 96
32033244 case 104 :
32043245 {
32053246 catchUp_ = input .readBool ();
3206- bitField0_ |= 0x00040000 ;
3247+ bitField0_ |= 0x00080000 ;
32073248 break ;
32083249 } // case 104
32093250 case 114 :
@@ -3239,7 +3280,7 @@ public Builder mergeFrom(
32393280 input .readMessage (
32403281 internalGetLastScheduledRunResponseFieldBuilder ().getBuilder (),
32413282 extensionRegistry );
3242- bitField0_ |= 0x00080000 ;
3283+ bitField0_ |= 0x00100000 ;
32433284 break ;
32443285 } // case 146
32453286 case 154 :
@@ -3257,6 +3298,12 @@ public Builder mergeFrom(
32573298 requestCase_ = 20 ;
32583299 break ;
32593300 } // case 162
3301+ case 168 :
3302+ {
3303+ maxConcurrentActiveRunCount_ = input .readInt64 ();
3304+ bitField0_ |= 0x00020000 ;
3305+ break ;
3306+ } // case 168
32603307 default :
32613308 {
32623309 if (!super .parseUnknownField (input , extensionRegistry , tag )) {
@@ -6338,6 +6385,77 @@ public Builder clearMaxConcurrentRunCount() {
63386385 return this ;
63396386 }
63406387
6388+ private long maxConcurrentActiveRunCount_ ;
6389+
6390+ /**
6391+ *
6392+ *
6393+ * <pre>
6394+ * Optional. Specifies the maximum number of active runs that can be executed
6395+ * concurrently for this Schedule. This limits the number of runs that can be
6396+ * in a non-terminal state at the same time.
6397+ * Currently, this field is only supported for requests of type
6398+ * CreatePipelineJobRequest.
6399+ * </pre>
6400+ *
6401+ * <code>int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
6402+ * </code>
6403+ *
6404+ * @return The maxConcurrentActiveRunCount.
6405+ */
6406+ @ java .lang .Override
6407+ public long getMaxConcurrentActiveRunCount () {
6408+ return maxConcurrentActiveRunCount_ ;
6409+ }
6410+
6411+ /**
6412+ *
6413+ *
6414+ * <pre>
6415+ * Optional. Specifies the maximum number of active runs that can be executed
6416+ * concurrently for this Schedule. This limits the number of runs that can be
6417+ * in a non-terminal state at the same time.
6418+ * Currently, this field is only supported for requests of type
6419+ * CreatePipelineJobRequest.
6420+ * </pre>
6421+ *
6422+ * <code>int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
6423+ * </code>
6424+ *
6425+ * @param value The maxConcurrentActiveRunCount to set.
6426+ * @return This builder for chaining.
6427+ */
6428+ public Builder setMaxConcurrentActiveRunCount (long value ) {
6429+
6430+ maxConcurrentActiveRunCount_ = value ;
6431+ bitField0_ |= 0x00020000 ;
6432+ onChanged ();
6433+ return this ;
6434+ }
6435+
6436+ /**
6437+ *
6438+ *
6439+ * <pre>
6440+ * Optional. Specifies the maximum number of active runs that can be executed
6441+ * concurrently for this Schedule. This limits the number of runs that can be
6442+ * in a non-terminal state at the same time.
6443+ * Currently, this field is only supported for requests of type
6444+ * CreatePipelineJobRequest.
6445+ * </pre>
6446+ *
6447+ * <code>int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
6448+ * </code>
6449+ *
6450+ * @return This builder for chaining.
6451+ */
6452+ public Builder clearMaxConcurrentActiveRunCount () {
6453+ bitField0_ = (bitField0_ & ~0x00020000 );
6454+ maxConcurrentActiveRunCount_ = 0L ;
6455+ onChanged ();
6456+ return this ;
6457+ }
6458+
63416459 private boolean allowQueueing_ ;
63426460
63436461 /**
@@ -6375,7 +6493,7 @@ public boolean getAllowQueueing() {
63756493 public Builder setAllowQueueing (boolean value ) {
63766494
63776495 allowQueueing_ = value ;
6378- bitField0_ |= 0x00020000 ;
6496+ bitField0_ |= 0x00040000 ;
63796497 onChanged ();
63806498 return this ;
63816499 }
@@ -6394,7 +6512,7 @@ public Builder setAllowQueueing(boolean value) {
63946512 * @return This builder for chaining.
63956513 */
63966514 public Builder clearAllowQueueing () {
6397- bitField0_ = (bitField0_ & ~0x00020000 );
6515+ bitField0_ = (bitField0_ & ~0x00040000 );
63986516 allowQueueing_ = false ;
63996517 onChanged ();
64006518 return this ;
@@ -6437,7 +6555,7 @@ public boolean getCatchUp() {
64376555 public Builder setCatchUp (boolean value ) {
64386556
64396557 catchUp_ = value ;
6440- bitField0_ |= 0x00040000 ;
6558+ bitField0_ |= 0x00080000 ;
64416559 onChanged ();
64426560 return this ;
64436561 }
@@ -6456,7 +6574,7 @@ public Builder setCatchUp(boolean value) {
64566574 * @return This builder for chaining.
64576575 */
64586576 public Builder clearCatchUp () {
6459- bitField0_ = (bitField0_ & ~0x00040000 );
6577+ bitField0_ = (bitField0_ & ~0x00080000 );
64606578 catchUp_ = false ;
64616579 onChanged ();
64626580 return this ;
@@ -6486,7 +6604,7 @@ public Builder clearCatchUp() {
64866604 * @return Whether the lastScheduledRunResponse field is set.
64876605 */
64886606 public boolean hasLastScheduledRunResponse () {
6489- return ((bitField0_ & 0x00080000 ) != 0 );
6607+ return ((bitField0_ & 0x00100000 ) != 0 );
64906608 }
64916609
64926610 /**
@@ -6539,7 +6657,7 @@ public Builder setLastScheduledRunResponse(
65396657 } else {
65406658 lastScheduledRunResponseBuilder_ .setMessage (value );
65416659 }
6542- bitField0_ |= 0x00080000 ;
6660+ bitField0_ |= 0x00100000 ;
65436661 onChanged ();
65446662 return this ;
65456663 }
@@ -6565,7 +6683,7 @@ public Builder setLastScheduledRunResponse(
65656683 } else {
65666684 lastScheduledRunResponseBuilder_ .setMessage (builderForValue .build ());
65676685 }
6568- bitField0_ |= 0x00080000 ;
6686+ bitField0_ |= 0x00100000 ;
65696687 onChanged ();
65706688 return this ;
65716689 }
@@ -6587,7 +6705,7 @@ public Builder setLastScheduledRunResponse(
65876705 public Builder mergeLastScheduledRunResponse (
65886706 com .google .cloud .aiplatform .v1beta1 .Schedule .RunResponse value ) {
65896707 if (lastScheduledRunResponseBuilder_ == null ) {
6590- if (((bitField0_ & 0x00080000 ) != 0 )
6708+ if (((bitField0_ & 0x00100000 ) != 0 )
65916709 && lastScheduledRunResponse_ != null
65926710 && lastScheduledRunResponse_
65936711 != com .google .cloud .aiplatform .v1beta1 .Schedule .RunResponse .getDefaultInstance ()) {
@@ -6599,7 +6717,7 @@ public Builder mergeLastScheduledRunResponse(
65996717 lastScheduledRunResponseBuilder_ .mergeFrom (value );
66006718 }
66016719 if (lastScheduledRunResponse_ != null ) {
6602- bitField0_ |= 0x00080000 ;
6720+ bitField0_ |= 0x00100000 ;
66036721 onChanged ();
66046722 }
66056723 return this ;
@@ -6620,7 +6738,7 @@ public Builder mergeLastScheduledRunResponse(
66206738 * </code>
66216739 */
66226740 public Builder clearLastScheduledRunResponse () {
6623- bitField0_ = (bitField0_ & ~0x00080000 );
6741+ bitField0_ = (bitField0_ & ~0x00100000 );
66246742 lastScheduledRunResponse_ = null ;
66256743 if (lastScheduledRunResponseBuilder_ != null ) {
66266744 lastScheduledRunResponseBuilder_ .dispose ();
@@ -6646,7 +6764,7 @@ public Builder clearLastScheduledRunResponse() {
66466764 */
66476765 public com .google .cloud .aiplatform .v1beta1 .Schedule .RunResponse .Builder
66486766 getLastScheduledRunResponseBuilder () {
6649- bitField0_ |= 0x00080000 ;
6767+ bitField0_ |= 0x00100000 ;
66506768 onChanged ();
66516769 return internalGetLastScheduledRunResponseFieldBuilder ().getBuilder ();
66526770 }
0 commit comments