SrSSKJr SSKJr "SS\R 5r"SS\5r"SS \5r "S S \5r g ) zAPI Library for gcloud tasks.) list_pager) exceptionsc\rSrSrSrSrg)"ModifyingPullAndAppEngineTaskErrorzEError for when attempt to create a queue as both pull and App Engine.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r)lib/googlecloudsdk/api_lib/tasks/tasks.pyrrsMrrc>\rSrSrSrSrS SjrS SjrSrSr S r g) BaseTasks!API client for Cloud Tasks tasks.cXlX lgNmessages tasks_service)selfrrs r__init__BaseTasks.__init__s M&rNc URRUR5S9n[R"UR XCUSSS9$)N)parenttaskspageSize) batch_sizelimitfieldbatch_size_attribute)r1CloudtasksProjectsLocationsQueuesTasksListRequest RelativeNamer YieldFromListr)r parent_refr" page_sizerequests rListBaseTasks.List!sR GG**, H .   # # GJ 88rcURRUR5US9nURR U5$)N)name responseView)r0CloudtasksProjectsLocationsQueuesTasksGetRequestr&rGet)rtask_ref response_viewr*s rr1 BaseTasks.Get)sG FF&&(& G (     ! !' **rcURRUR5S9nURR U5$N)r.)r3CloudtasksProjectsLocationsQueuesTasksDeleteRequestr&rDeleterr2r*s rr8BaseTasks.Delete0sD II&&( J *     $ $W --rcURRUR5S9nURR U5$r6)r0CloudtasksProjectsLocationsQueuesTasksRunRequestr&rRunr9s rr= BaseTasks.Run6sD FF&&( G *     ! !' **rr)Ndr) r r r r r rr+r1r8r=rrrrrrs)'8+. +rrc0\rSrSrSrSSjrSSjrSrg) Tasks=rNc6U(aUR5OSnURRXcUS9nU(aXWlURR URR US9UR5S9nUR RU5$)8Prepares and sends a Create request for creating a task.N)r. scheduleTimeappEngineHttpRequesttaskcreateTaskRequestr)r&rTask httpRequest3CloudtasksProjectsLocationsQueuesTasksCreateRequestCreateTaskRequestrCreate) rr(r2 schedule_timeapp_engine_http_request http_requestr.rHr*s rrO Tasks.Create@s'/8 "DD ==   4  6D% II"mm==4=H**, J .     $ $W --rcURRUR5US9nURR U5$z9Prepares and sends a Create request for buffering a task.)queuetaskIdr3CloudtasksProjectsLocationsQueuesTasksBufferRequestr&rBufferrr(task_idr*s rrZ Tasks.BufferOsCmmOO%%'PG    $ $W --rrNNNN)r r r r r rOrZrrrrrArA=s)<@8< ..rrAcP\rSrSrSrS SjrS SjrSrSrS Sjr S r S r g) AlphaTasksWrcURRUR5US9nURR U5$rUrXr[s rrZAlphaTasks.BufferZsCmmOO%%'P9G    $ $W --rNcPU(aU(a [S5eU(aUR5OSnURRXcUUS9nURR URR US9UR5S9nUR RU5$)rDzFAttempting to send PullMessage and AppEngineHttpRequest simultaneouslyN)r.rE pullMessagerFrGrI)rr&rrKrMrNrrO) rr(r2rP pull_messagerQr.rHr*s rrOAlphaTasks.Createas/ .  '/8 "DD ==   <4  6D II"mm==4=H**, J .     $ $W --rcURRX#S9nURRnU"UUR5S9nURR U5$)aConstructs and sends a tasks RenewLease request to the Cloud Tasks API. Args: task_ref: A cloudtasks.projects.locations.queues.tasks resource reference schedule_time: string formatted as an ISO 8601 datetime with timezone lease_duration: string of an integer followed by 's', (e.g. '10s') for the number of seconds for the new lease Returns: The response of the tasks RenewLease request )rE leaseDuration)renewLeaseRequestr.)rRenewLeaseRequest7CloudtasksProjectsLocationsQueuesTasksRenewLeaseRequestr&r RenewLease)rr2rPlease_durationrenew_lease_request request_clsr*s rroAlphaTasks.RenewLeasersd--99":B==JJ,?'4468G    ( ( 11rcURRUS9nURRnU"UUR5S9nURR U5$)aConstructs and sends a tasks CancelLease request to the Cloud Tasks API. Args: task_ref: A cloudtasks.projects.locations.queues.tasks resource reference schedule_time: string formatted as an ISO 8601 datetime with timezone Returns: The response of the tasks CancelLease request rE)cancelLeaseRequestr.)rCancelLeaseRequest8CloudtasksProjectsLocationsQueuesTasksCancelLeaseRequestr&r CancelLease)rr2rPcancel_lease_requestrrr*s rryAlphaTasks.CancelLeasesc ==;;"<$==KK-A'4468G    ) )' 22rcURRX2US9nURRUUR5S9nURR U5$)aConstructs and sends a LeaseTasks request to the Cloud Tasks API. Args: queue_ref: A cloudtasks.projects.locations.queues resource reference lease_duration: string of an integer followed by 's', (e.g. '10s') for the number of seconds for the new leases filter_string: string with an expression to filter which tasks are leased max_tasks: the maximum number of tasks to lease Returns: The response of the LeaseTasks request )filterrkmaxTasks)leaseTasksRequestr)rLeaseTasksRequest2CloudtasksProjectsLocationsQueuesTasksLeaseRequestr&rLease)r queue_refrp filter_string max_taskslease_tasks_requestr*s rrAlphaTasks.Leasesk--99Y:P HH1))+ I -     # #G ,,rcURRUS9nURRnU"UUR5S9nURR U5$)aConstructs and sends a tasks Acknowledge request to the Cloud Tasks API. Args: task_ref: A cloudtasks.projects.locations.queues.tasks resource reference schedule_time: string formatted as an ISO 8601 datetime with timezone Returns: The response of the tasks Acknowledge request ru)acknowledgeTaskRequestr.)rAcknowledgeTaskRequest8CloudtasksProjectsLocationsQueuesTasksAcknowledgeRequestr&r Acknowledge)rr2rPacknowledge_task_requestrrr*s rrAlphaTasks.Acknowledgesd $}}CC" D $==KK1I'4468G    ) )' 22rrr_r^)NN) r r r r r rZrOroryrrrrrrrbrbWs5).=A8<."2&3$<@-,3rrbN) r apitools.base.pyrgooglecloudsdk.corer InternalErrorrobjectrrArbrrrrsM$(*N)A)AN + +F.I.4f3f3r