SrSSKJr SSKJr SSKJr SSKJr SSKJr "SS\R5r "S S \ 5r "S S \ 5r "S S\ 5rg)zAPI Library for gcloud tasks.)absolute_import)division)unicode_literals) 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.pyr r sMrr c>\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 rr4 BaseTasks.Get,sG FF&&(& G (     ! !' **rcURRUR5S9nURR U5$N)r1)r3CloudtasksProjectsLocationsQueuesTasksDeleteRequestr)rDeleterr5r-s rr;BaseTasks.Delete3sD II&&( J *     $ $W --rcURRUR5S9nURR U5$r9)r0CloudtasksProjectsLocationsQueuesTasksRunRequestr)rRunr<s rr@ BaseTasks.Run9sD FF&&( G *     ! !' **rr)Ndr) r r rrrrr.r4r;r@rr rrrrs)'8+. +rrc0\rSrSrSrSSjrSSjrSrg) Tasks@rNc6U(aUR5OSnURRXcUS9nU(aXWlURR URR US9UR5S9nUR RU5$)8Prepares and sends a Create request for creating a task.N)r1 scheduleTimeappEngineHttpRequesttaskcreateTaskRequestr!)r)rTask httpRequest3CloudtasksProjectsLocationsQueuesTasksCreateRequestCreateTaskRequestrCreate) rr+r5 schedule_timeapp_engine_http_request http_requestr1rKr-s rrR Tasks.CreateCs'/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 rr] Tasks.BufferRsCmmOO%%'PG    $ $W --rr NNNN)r r rrrrRr]rr rrrDrD@s)<@8< ..rrDcP\rSrSrSrS SjrS SjrSrSrS Sjr S r S r g) AlphaTasksZrcURRUR5US9nURR U5$rXr[r^s rr]AlphaTasks.Buffer]sCmmOO%%'P9G    $ $W --rNcPU(aU(a [S5eU(aUR5OSnURRXcUUS9nURR URR US9UR5S9nUR RU5$)rGzFAttempting to send PullMessage and AppEngineHttpRequest simultaneouslyN)r1rH pullMessagerIrJrL)r r)rrNrPrQrrR) rr+r5rS pull_messagerTr1rKr-s rrRAlphaTasks.Createds/ .  '/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 )rH leaseDuration)renewLeaseRequestr1)rRenewLeaseRequest7CloudtasksProjectsLocationsQueuesTasksRenewLeaseRequestr)r RenewLease)rr5rSlease_durationrenew_lease_request request_clsr-s rrrAlphaTasks.RenewLeaseusd--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 rH)cancelLeaseRequestr1)rCancelLeaseRequest8CloudtasksProjectsLocationsQueuesTasksCancelLeaseRequestr)r CancelLease)rr5rScancel_lease_requestrur-s rr|AlphaTasks.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 )filterrnmaxTasks)leaseTasksRequestr!)rLeaseTasksRequest2CloudtasksProjectsLocationsQueuesTasksLeaseRequestr)rLease)r queue_refrs 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 rx)acknowledgeTaskRequestr1)rAcknowledgeTaskRequest8CloudtasksProjectsLocationsQueuesTasksAcknowledgeRequestr)r Acknowledge)rr5rSacknowledge_task_requestrur-s rrAlphaTasks.Acknowledgesd $}}CC" D $==KK1I'4468G    ) )' 22rr rbra)NN) r r rrrr]rRrrr|rrrr rrrereZs5).=A8<."2&3$<@-,3rreN)r __future__rrrapitools.base.pyrgooglecloudsdk.corer InternalErrorr objectrrDrer rrrsT$&''*N)A)AN + +F.I.4f3f3r