diff --git a/AiPlatform/metadata/V1/Schedule.php b/AiPlatform/metadata/V1/Schedule.php
index 234f0d984db3..fde461d23b48 100644
Binary files a/AiPlatform/metadata/V1/Schedule.php and b/AiPlatform/metadata/V1/Schedule.php differ
diff --git a/AiPlatform/src/V1/Schedule.php b/AiPlatform/src/V1/Schedule.php
index fa3c4224c8e4..6895bbc81a5d 100644
--- a/AiPlatform/src/V1/Schedule.php
+++ b/AiPlatform/src/V1/Schedule.php
@@ -113,6 +113,16 @@ class Schedule extends \Google\Protobuf\Internal\Message
* Generated from protobuf field int64 max_concurrent_run_count = 11 [(.google.api.field_behavior) = REQUIRED];
*/
protected $max_concurrent_run_count = 0;
+ /**
+ * 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.
+ *
+ * Generated from protobuf field int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
+ */
+ protected $max_concurrent_active_run_count = 0;
/**
* Optional. Whether new scheduled runs can be queued when max_concurrent_runs
* limit is reached. If set to true, new runs will be queued instead of
@@ -207,6 +217,12 @@ class Schedule extends \Google\Protobuf\Internal\Message
* Required. Maximum number of runs that can be started concurrently for this
* Schedule. This is the limit for starting the scheduled requests and not the
* execution of the operations/jobs created by the requests (if applicable).
+ * @type int|string $max_concurrent_active_run_count
+ * 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.
* @type bool $allow_queueing
* Optional. Whether new scheduled runs can be queued when max_concurrent_runs
* limit is reached. If set to true, new runs will be queued instead of
@@ -784,6 +800,40 @@ public function setMaxConcurrentRunCount($var)
return $this;
}
+ /**
+ * 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.
+ *
+ * Generated from protobuf field int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
+ * @return int|string
+ */
+ public function getMaxConcurrentActiveRunCount()
+ {
+ return $this->max_concurrent_active_run_count;
+ }
+
+ /**
+ * 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.
+ *
+ * Generated from protobuf field int64 max_concurrent_active_run_count = 21 [(.google.api.field_behavior) = OPTIONAL];
+ * @param int|string $var
+ * @return $this
+ */
+ public function setMaxConcurrentActiveRunCount($var)
+ {
+ GPBUtil::checkInt64($var);
+ $this->max_concurrent_active_run_count = $var;
+
+ return $this;
+ }
+
/**
* Optional. Whether new scheduled runs can be queued when max_concurrent_runs
* limit is reached. If set to true, new runs will be queued instead of
diff --git a/AiPlatform/tests/Unit/V1/Client/ScheduleServiceClientTest.php b/AiPlatform/tests/Unit/V1/Client/ScheduleServiceClientTest.php
index 9da175606c68..9c25b1fd29b8 100644
--- a/AiPlatform/tests/Unit/V1/Client/ScheduleServiceClientTest.php
+++ b/AiPlatform/tests/Unit/V1/Client/ScheduleServiceClientTest.php
@@ -99,6 +99,7 @@ public function createScheduleTest()
$maxRunCount = 845001408;
$startedRunCount = 479303651;
$maxConcurrentRunCount = 1478623794;
+ $maxConcurrentActiveRunCount = 2066355825;
$allowQueueing = false;
$catchUp = false;
$expectedResponse = new Schedule();
@@ -108,6 +109,7 @@ public function createScheduleTest()
$expectedResponse->setMaxRunCount($maxRunCount);
$expectedResponse->setStartedRunCount($startedRunCount);
$expectedResponse->setMaxConcurrentRunCount($maxConcurrentRunCount);
+ $expectedResponse->setMaxConcurrentActiveRunCount($maxConcurrentActiveRunCount);
$expectedResponse->setAllowQueueing($allowQueueing);
$expectedResponse->setCatchUp($catchUp);
$transport->addResponse($expectedResponse);
@@ -312,6 +314,7 @@ public function getScheduleTest()
$maxRunCount = 845001408;
$startedRunCount = 479303651;
$maxConcurrentRunCount = 1478623794;
+ $maxConcurrentActiveRunCount = 2066355825;
$allowQueueing = false;
$catchUp = false;
$expectedResponse = new Schedule();
@@ -321,6 +324,7 @@ public function getScheduleTest()
$expectedResponse->setMaxRunCount($maxRunCount);
$expectedResponse->setStartedRunCount($startedRunCount);
$expectedResponse->setMaxConcurrentRunCount($maxConcurrentRunCount);
+ $expectedResponse->setMaxConcurrentActiveRunCount($maxConcurrentActiveRunCount);
$expectedResponse->setAllowQueueing($allowQueueing);
$expectedResponse->setCatchUp($catchUp);
$transport->addResponse($expectedResponse);
@@ -586,6 +590,7 @@ public function updateScheduleTest()
$maxRunCount = 845001408;
$startedRunCount = 479303651;
$maxConcurrentRunCount = 1478623794;
+ $maxConcurrentActiveRunCount = 2066355825;
$allowQueueing = false;
$catchUp = false;
$expectedResponse = new Schedule();
@@ -595,6 +600,7 @@ public function updateScheduleTest()
$expectedResponse->setMaxRunCount($maxRunCount);
$expectedResponse->setStartedRunCount($startedRunCount);
$expectedResponse->setMaxConcurrentRunCount($maxConcurrentRunCount);
+ $expectedResponse->setMaxConcurrentActiveRunCount($maxConcurrentActiveRunCount);
$expectedResponse->setAllowQueueing($allowQueueing);
$expectedResponse->setCatchUp($catchUp);
$transport->addResponse($expectedResponse);
@@ -1010,6 +1016,7 @@ public function createScheduleAsyncTest()
$maxRunCount = 845001408;
$startedRunCount = 479303651;
$maxConcurrentRunCount = 1478623794;
+ $maxConcurrentActiveRunCount = 2066355825;
$allowQueueing = false;
$catchUp = false;
$expectedResponse = new Schedule();
@@ -1019,6 +1026,7 @@ public function createScheduleAsyncTest()
$expectedResponse->setMaxRunCount($maxRunCount);
$expectedResponse->setStartedRunCount($startedRunCount);
$expectedResponse->setMaxConcurrentRunCount($maxConcurrentRunCount);
+ $expectedResponse->setMaxConcurrentActiveRunCount($maxConcurrentActiveRunCount);
$expectedResponse->setAllowQueueing($allowQueueing);
$expectedResponse->setCatchUp($catchUp);
$transport->addResponse($expectedResponse);