@@ -2154,6 +2154,30 @@ public long getMaxConcurrentRunCount() {
21542154 return maxConcurrentRunCount_ ;
21552155 }
21562156
2157+ public static final int MAX_CONCURRENT_ACTIVE_RUN_COUNT_FIELD_NUMBER = 21 ;
2158+ private long maxConcurrentActiveRunCount_ = 0L ;
2159+
2160+ /**
2161+ *
2162+ *
2163+ * <pre>
2164+ * Optional. Specifies the maximum number of active runs that can be executed
2165+ * concurrently for this Schedule. This limits the number of runs that can be
2166+ * in a non-terminal state at the same time.
2167+ * Currently, this field is only supported for requests of type
2168+ * CreatePipelineJobRequest.
2169+ * </pre>
2170+ *
2171+ * <code>int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
2172+ * </code>
2173+ *
2174+ * @return The maxConcurrentActiveRunCount.
2175+ */
2176+ @ java .lang .Override
2177+ public long getMaxConcurrentActiveRunCount () {
2178+ return maxConcurrentActiveRunCount_ ;
2179+ }
2180+
21572181 public static final int ALLOW_QUEUEING_FIELD_NUMBER = 12 ;
21582182 private boolean allowQueueing_ = false ;
21592183
@@ -2337,6 +2361,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
23372361 output .writeMessage (
23382362 20 , (com .google .cloud .aiplatform .v1 .CreateNotebookExecutionJobRequest ) request_ );
23392363 }
2364+ if (maxConcurrentActiveRunCount_ != 0L ) {
2365+ output .writeInt64 (21 , maxConcurrentActiveRunCount_ );
2366+ }
23402367 getUnknownFields ().writeTo (output );
23412368 }
23422369
@@ -2409,6 +2436,10 @@ public int getSerializedSize() {
24092436 com .google .protobuf .CodedOutputStream .computeMessageSize (
24102437 20 , (com .google .cloud .aiplatform .v1 .CreateNotebookExecutionJobRequest ) request_ );
24112438 }
2439+ if (maxConcurrentActiveRunCount_ != 0L ) {
2440+ size +=
2441+ com .google .protobuf .CodedOutputStream .computeInt64Size (21 , maxConcurrentActiveRunCount_ );
2442+ }
24122443 size += getUnknownFields ().getSerializedSize ();
24132444 memoizedSize = size ;
24142445 return size ;
@@ -2458,6 +2489,7 @@ public boolean equals(final java.lang.Object obj) {
24582489 if (!getLastResumeTime ().equals (other .getLastResumeTime ())) return false ;
24592490 }
24602491 if (getMaxConcurrentRunCount () != other .getMaxConcurrentRunCount ()) return false ;
2492+ if (getMaxConcurrentActiveRunCount () != other .getMaxConcurrentActiveRunCount ()) return false ;
24612493 if (getAllowQueueing () != other .getAllowQueueing ()) return false ;
24622494 if (getCatchUp () != other .getCatchUp ()) return false ;
24632495 if (hasLastScheduledRunResponse () != other .hasLastScheduledRunResponse ()) return false ;
@@ -2536,6 +2568,8 @@ public int hashCode() {
25362568 }
25372569 hash = (37 * hash ) + MAX_CONCURRENT_RUN_COUNT_FIELD_NUMBER ;
25382570 hash = (53 * hash ) + com .google .protobuf .Internal .hashLong (getMaxConcurrentRunCount ());
2571+ hash = (37 * hash ) + MAX_CONCURRENT_ACTIVE_RUN_COUNT_FIELD_NUMBER ;
2572+ hash = (53 * hash ) + com .google .protobuf .Internal .hashLong (getMaxConcurrentActiveRunCount ());
25392573 hash = (37 * hash ) + ALLOW_QUEUEING_FIELD_NUMBER ;
25402574 hash = (53 * hash ) + com .google .protobuf .Internal .hashBoolean (getAllowQueueing ());
25412575 hash = (37 * hash ) + CATCH_UP_FIELD_NUMBER ;
@@ -2768,6 +2802,7 @@ public Builder clear() {
27682802 lastResumeTimeBuilder_ = null ;
27692803 }
27702804 maxConcurrentRunCount_ = 0L ;
2805+ maxConcurrentActiveRunCount_ = 0L ;
27712806 allowQueueing_ = false ;
27722807 catchUp_ = false ;
27732808 lastScheduledRunResponse_ = null ;
@@ -2867,12 +2902,15 @@ private void buildPartial0(com.google.cloud.aiplatform.v1.Schedule result) {
28672902 result .maxConcurrentRunCount_ = maxConcurrentRunCount_ ;
28682903 }
28692904 if (((from_bitField0_ & 0x00010000 ) != 0 )) {
2870- result .allowQueueing_ = allowQueueing_ ;
2905+ result .maxConcurrentActiveRunCount_ = maxConcurrentActiveRunCount_ ;
28712906 }
28722907 if (((from_bitField0_ & 0x00020000 ) != 0 )) {
2873- result .catchUp_ = catchUp_ ;
2908+ result .allowQueueing_ = allowQueueing_ ;
28742909 }
28752910 if (((from_bitField0_ & 0x00040000 ) != 0 )) {
2911+ result .catchUp_ = catchUp_ ;
2912+ }
2913+ if (((from_bitField0_ & 0x00080000 ) != 0 )) {
28762914 result .lastScheduledRunResponse_ =
28772915 lastScheduledRunResponseBuilder_ == null
28782916 ? lastScheduledRunResponse_
@@ -2950,6 +2988,9 @@ public Builder mergeFrom(com.google.cloud.aiplatform.v1.Schedule other) {
29502988 if (other .getMaxConcurrentRunCount () != 0L ) {
29512989 setMaxConcurrentRunCount (other .getMaxConcurrentRunCount ());
29522990 }
2991+ if (other .getMaxConcurrentActiveRunCount () != 0L ) {
2992+ setMaxConcurrentActiveRunCount (other .getMaxConcurrentActiveRunCount ());
2993+ }
29532994 if (other .getAllowQueueing () != false ) {
29542995 setAllowQueueing (other .getAllowQueueing ());
29552996 }
@@ -3089,13 +3130,13 @@ public Builder mergeFrom(
30893130 case 96 :
30903131 {
30913132 allowQueueing_ = input .readBool ();
3092- bitField0_ |= 0x00010000 ;
3133+ bitField0_ |= 0x00020000 ;
30933134 break ;
30943135 } // case 96
30953136 case 104 :
30963137 {
30973138 catchUp_ = input .readBool ();
3098- bitField0_ |= 0x00020000 ;
3139+ bitField0_ |= 0x00040000 ;
30993140 break ;
31003141 } // case 104
31013142 case 114 :
@@ -3123,7 +3164,7 @@ public Builder mergeFrom(
31233164 input .readMessage (
31243165 internalGetLastScheduledRunResponseFieldBuilder ().getBuilder (),
31253166 extensionRegistry );
3126- bitField0_ |= 0x00040000 ;
3167+ bitField0_ |= 0x00080000 ;
31273168 break ;
31283169 } // case 146
31293170 case 154 :
@@ -3141,6 +3182,12 @@ public Builder mergeFrom(
31413182 requestCase_ = 20 ;
31423183 break ;
31433184 } // case 162
3185+ case 168 :
3186+ {
3187+ maxConcurrentActiveRunCount_ = input .readInt64 ();
3188+ bitField0_ |= 0x00010000 ;
3189+ break ;
3190+ } // case 168
31443191 default :
31453192 {
31463193 if (!super .parseUnknownField (input , extensionRegistry , tag )) {
@@ -5946,6 +5993,77 @@ public Builder clearMaxConcurrentRunCount() {
59465993 return this ;
59475994 }
59485995
5996+ private long maxConcurrentActiveRunCount_ ;
5997+
5998+ /**
5999+ *
6000+ *
6001+ * <pre>
6002+ * Optional. Specifies the maximum number of active runs that can be executed
6003+ * concurrently for this Schedule. This limits the number of runs that can be
6004+ * in a non-terminal state at the same time.
6005+ * Currently, this field is only supported for requests of type
6006+ * CreatePipelineJobRequest.
6007+ * </pre>
6008+ *
6009+ * <code>int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
6010+ * </code>
6011+ *
6012+ * @return The maxConcurrentActiveRunCount.
6013+ */
6014+ @ java .lang .Override
6015+ public long getMaxConcurrentActiveRunCount () {
6016+ return maxConcurrentActiveRunCount_ ;
6017+ }
6018+
6019+ /**
6020+ *
6021+ *
6022+ * <pre>
6023+ * Optional. Specifies the maximum number of active runs that can be executed
6024+ * concurrently for this Schedule. This limits the number of runs that can be
6025+ * in a non-terminal state at the same time.
6026+ * Currently, this field is only supported for requests of type
6027+ * CreatePipelineJobRequest.
6028+ * </pre>
6029+ *
6030+ * <code>int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
6031+ * </code>
6032+ *
6033+ * @param value The maxConcurrentActiveRunCount to set.
6034+ * @return This builder for chaining.
6035+ */
6036+ public Builder setMaxConcurrentActiveRunCount (long value ) {
6037+
6038+ maxConcurrentActiveRunCount_ = value ;
6039+ bitField0_ |= 0x00010000 ;
6040+ onChanged ();
6041+ return this ;
6042+ }
6043+
6044+ /**
6045+ *
6046+ *
6047+ * <pre>
6048+ * Optional. Specifies the maximum number of active runs that can be executed
6049+ * concurrently for this Schedule. This limits the number of runs that can be
6050+ * in a non-terminal state at the same time.
6051+ * Currently, this field is only supported for requests of type
6052+ * CreatePipelineJobRequest.
6053+ * </pre>
6054+ *
6055+ * <code>int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
6056+ * </code>
6057+ *
6058+ * @return This builder for chaining.
6059+ */
6060+ public Builder clearMaxConcurrentActiveRunCount () {
6061+ bitField0_ = (bitField0_ & ~0x00010000 );
6062+ maxConcurrentActiveRunCount_ = 0L ;
6063+ onChanged ();
6064+ return this ;
6065+ }
6066+
59496067 private boolean allowQueueing_ ;
59506068
59516069 /**
@@ -5983,7 +6101,7 @@ public boolean getAllowQueueing() {
59836101 public Builder setAllowQueueing (boolean value ) {
59846102
59856103 allowQueueing_ = value ;
5986- bitField0_ |= 0x00010000 ;
6104+ bitField0_ |= 0x00020000 ;
59876105 onChanged ();
59886106 return this ;
59896107 }
@@ -6002,7 +6120,7 @@ public Builder setAllowQueueing(boolean value) {
60026120 * @return This builder for chaining.
60036121 */
60046122 public Builder clearAllowQueueing () {
6005- bitField0_ = (bitField0_ & ~0x00010000 );
6123+ bitField0_ = (bitField0_ & ~0x00020000 );
60066124 allowQueueing_ = false ;
60076125 onChanged ();
60086126 return this ;
@@ -6045,7 +6163,7 @@ public boolean getCatchUp() {
60456163 public Builder setCatchUp (boolean value ) {
60466164
60476165 catchUp_ = value ;
6048- bitField0_ |= 0x00020000 ;
6166+ bitField0_ |= 0x00040000 ;
60496167 onChanged ();
60506168 return this ;
60516169 }
@@ -6064,7 +6182,7 @@ public Builder setCatchUp(boolean value) {
60646182 * @return This builder for chaining.
60656183 */
60666184 public Builder clearCatchUp () {
6067- bitField0_ = (bitField0_ & ~0x00020000 );
6185+ bitField0_ = (bitField0_ & ~0x00040000 );
60686186 catchUp_ = false ;
60696187 onChanged ();
60706188 return this ;
@@ -6094,7 +6212,7 @@ public Builder clearCatchUp() {
60946212 * @return Whether the lastScheduledRunResponse field is set.
60956213 */
60966214 public boolean hasLastScheduledRunResponse () {
6097- return ((bitField0_ & 0x00040000 ) != 0 );
6215+ return ((bitField0_ & 0x00080000 ) != 0 );
60986216 }
60996217
61006218 /**
@@ -6147,7 +6265,7 @@ public Builder setLastScheduledRunResponse(
61476265 } else {
61486266 lastScheduledRunResponseBuilder_ .setMessage (value );
61496267 }
6150- bitField0_ |= 0x00040000 ;
6268+ bitField0_ |= 0x00080000 ;
61516269 onChanged ();
61526270 return this ;
61536271 }
@@ -6173,7 +6291,7 @@ public Builder setLastScheduledRunResponse(
61736291 } else {
61746292 lastScheduledRunResponseBuilder_ .setMessage (builderForValue .build ());
61756293 }
6176- bitField0_ |= 0x00040000 ;
6294+ bitField0_ |= 0x00080000 ;
61776295 onChanged ();
61786296 return this ;
61796297 }
@@ -6195,7 +6313,7 @@ public Builder setLastScheduledRunResponse(
61956313 public Builder mergeLastScheduledRunResponse (
61966314 com .google .cloud .aiplatform .v1 .Schedule .RunResponse value ) {
61976315 if (lastScheduledRunResponseBuilder_ == null ) {
6198- if (((bitField0_ & 0x00040000 ) != 0 )
6316+ if (((bitField0_ & 0x00080000 ) != 0 )
61996317 && lastScheduledRunResponse_ != null
62006318 && lastScheduledRunResponse_
62016319 != com .google .cloud .aiplatform .v1 .Schedule .RunResponse .getDefaultInstance ()) {
@@ -6207,7 +6325,7 @@ public Builder mergeLastScheduledRunResponse(
62076325 lastScheduledRunResponseBuilder_ .mergeFrom (value );
62086326 }
62096327 if (lastScheduledRunResponse_ != null ) {
6210- bitField0_ |= 0x00040000 ;
6328+ bitField0_ |= 0x00080000 ;
62116329 onChanged ();
62126330 }
62136331 return this ;
@@ -6228,7 +6346,7 @@ public Builder mergeLastScheduledRunResponse(
62286346 * </code>
62296347 */
62306348 public Builder clearLastScheduledRunResponse () {
6231- bitField0_ = (bitField0_ & ~0x00040000 );
6349+ bitField0_ = (bitField0_ & ~0x00080000 );
62326350 lastScheduledRunResponse_ = null ;
62336351 if (lastScheduledRunResponseBuilder_ != null ) {
62346352 lastScheduledRunResponseBuilder_ .dispose ();
@@ -6254,7 +6372,7 @@ public Builder clearLastScheduledRunResponse() {
62546372 */
62556373 public com .google .cloud .aiplatform .v1 .Schedule .RunResponse .Builder
62566374 getLastScheduledRunResponseBuilder () {
6257- bitField0_ |= 0x00040000 ;
6375+ bitField0_ |= 0x00080000 ;
62586376 onChanged ();
62596377 return internalGetLastScheduledRunResponseFieldBuilder ().getBuilder ();
62606378 }
0 commit comments