* dZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z e jZejZd Zd Zd Zd Zd Z ddedej*dedefdZdZdedej*dej2fdZdedej*dej2fdZdZdZdZdZdZ d dedej*defdZ!dZ"dZ#y)!z'Notebook-executor schedules api helper.N) executions) exceptions)parser_extensions) resources)times)aiplatform_v1beta1_clientcf|jjjjS)zGet the resource name for the schedule. Args: args: Argparse object from Command.Run Returns: The resource name in the form projects/{project}/locations/{location}/schedules/{schedule_id}. )CONCEPTSscheduleParse RelativeNameargss 9lib/googlecloudsdk/api_lib/notebook_executor/schedules.pyGetScheduleResourceNamers&    % % ' 4 4 66cd|vr" tjj|dStjj|dS#tj$rY6wxYw)zParse operation relative resource name to the operation reference object. Args: operation_name: The schedule operation resource name Returns: The operation reference object z /schedules/z2aiplatform.projects.locations.schedules.operations) collectionz(aiplatform.projects.locations.operations)rREGISTRYParseRelativeName WrongResourceCollectionException)operation_names rParseScheduleOperationr,sun$    1 1 B2    - -!K .   5 5   s AAActtjj|jdj S)z$Get the URL for a schedule resource.z'aiplatform.projects.locations.schedules) relative_namer)rrrnameSelfLink)resources rGetScheduleUrirDs3    - -MM: .  HJrc\|jrtj|jSdS)z$Get the start time for the schedule.N) start_timerFormatDateTimers r GetStartTimer#Ls"26//  doo .KtKrc\|jrtj|jSdS)z"Get the end time for the schedule.N)end_timerr"rs r GetEndTimer&Qs"04   dmm ,G4Grrmessages for_update for_workbenchc d}|stj|||}|j|jt |t ||j |j|j|j|S)a]Builds a Schedule message. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the specified API. for_update: Whether the schedule is to be used in an update request. for_workbench: Whether the schedule is for a Workbench execution. Returns: Instance of the Schedule message. N) displayName startTimeendTime maxRunCountcronmaxConcurrentRunCount allowQueueing!createNotebookExecutionJobRequest) executions_util'CreateExecutionCreateRequestForSchedule$GoogleCloudAiplatformV1beta1Schedule display_namer#r&max_runs cron_schedulemax_concurrent_runsenable_queueing)rr'r(r)execution_create_requests rCreateScheduler<Vs"" ?? (M   6 6##T"--    44(((@ 7  rcTtj|jjS)zList filter for Workbench schedules. Args: schedule: The schedule item returned from List API to check. Returns: True if the schedule is for a Workbench notebook execution. )r3IsWorkbenchExecutionr2notebookExecutionJob)r s rFilterWorkbenchScheduler@zs&  - -00EE rservicec|jt||}|j}|tjddt j |jrtjdd|S)aChecks if the schedule is for a Colab Enterprise notebook execution and returns the schedule if so. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the specified API. service: The service to use to make the request. Returns: The schedule if it is of Colab Enterprise type. Raises: InvalidArgumentException: If the schedule is not of notebook execution type or is of Workbench type. SCHEDULE+Schedule is not of notebook execution type.zlSchedule is not of Colab Enterprise type. To manage Workbench schedules use `gcloud beta workbench` instead.)GetCreateScheduleGetRequestr2rInvalidArgumentExceptionr3r>r?rr'rAr notebook_execution_job_requests rValidateAndGetColabSchedulerJs&[[1$A B(#+#M#M #+  - -A ))$99  - - :  /rc|jt||}|j}|tjdd|j j tjdd|S)aChecks if the schedule is for a Workbench notebook execution and returns the schedule if so. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the specified API. service: The service to use to make the request. Returns: The schedule if it is of Workbench type. Raises: InvalidArgumentException: If the schedule is not of notebook execution type. rCrDzmSchedule is not of Workbench type. To manage Colab Enterprise schedules use `gcloud colab schedules` instead.)rErFr2rrGr? kernelNamerHs rValidateAndGetWorkbenchSchedulerMs$[[tX.($,#M#M #+  - -A $88CCK  - - ;  /rc8|jt|S)zBuilds a SchedulesGetRequest message. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the specified API. Returns: Instance of the SchedulesGetRequest message. r).AiplatformProjectsLocationsSchedulesGetRequestrrr's rrFrFs$==&t,>rc8|jt|S)zBuilds a SchedulesDeleteRequest message. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the specified API. Returns: Instance of the SchedulesDeleteRequest message. rO)1AiplatformProjectsLocationsSchedulesDeleteRequestrrQs rCreateScheduleDeleteRequestrTs%@@&t,Arc8|jt|S)zBuilds a SchedulesPauseRequest message. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the specified API. Returns: Instance of the SchedulesPauseRequest message. rO)0AiplatformProjectsLocationsSchedulesPauseRequestrrQs rCreateSchedulePauseRequestrWs%??&t,@rcr|j|j}|jt||S)zBuilds a SchedulesResumeRequest message. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the specified API. Returns: Instance of the SchedulesResumeRequest message. )catchUp)r1googleCloudAiplatformV1beta1ResumeScheduleRequest)1GoogleCloudAiplatformV1beta1ResumeScheduleRequestenable_catch_up1AiplatformProjectsLocationsSchedulesResumeRequestr)rr'resume_schedule_requests rCreateScheduleResumeRequestr_sL@@&&A @@&t,%ArcN|jtj|dS)zBuilds a SchedulesListRequest message. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the specified API. Returns: Instance of the SchedulesListRequest message. z'create_notebook_execution_job_request:*)parentfilter)/AiplatformProjectsLocationsSchedulesListRequestr3GetParentForExecutionOrSchedulerQs rCreateScheduleListRequestres.  A A  <   B B "4 (+9 T,*$/ C r)FF)F)$__doc__types(googlecloudsdk.api_lib.notebook_executorrr3googlecloudsdk.callioperrgooglecloudsdk.corergooglecloudsdk.core.utilr8googlecloudsdk.generated_clients.apis.aiplatform.v1beta1rAiplatformV1beta1 Namespacerrrr#r& ModuleTypeboolr<r@!ProjectsLocationsSchedulesServicerJrMrFrTrWr_reriryr}rrrs5. R.5)*^.??  ' '  70L H ! !!! !H ! !! @ @!H     @ @ F$$$2 "HM $//@D*)2r