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);