z6pSrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r "SS \R5r "S S \R5r"S S \5r"SS\5r"SS\R5r"SS\R5r"SS\5r"SS\R(5rg)z"Pollers for Serverless operations.)absolute_import)division)print_function)unicode_literals)waiter) exceptionsc0\rSrSrSrSrSrSrSrSr g) !DomainMappingResourceRecordPollerz8Poll for when a DomainMapping first has resourceRecords.cXlgN_ops)selfopss 0lib/googlecloudsdk/command_lib/run/op_pollers.py__init__*DomainMappingResourceRecordPoller.__init__ sIc|[URSS5(agURnU(a USSSLagg)NresourceRecordsTReadystatusF)getattrr conditions)rmappingrs rIsDone(DomainMappingResourceRecordPoller.IsDone#s@w~~0$77 ##Jj)(3u<  rcU$r )rrs r GetResult+DomainMappingResourceRecordPoller.GetResult.s Nrc8URRU5$r )rGetDomainMapping)rdomain_mapping_refs rPoll&DomainMappingResourceRecordPoller.Poll1s 99 % %&8 99rrN) __name__ __module__ __qualname____firstlineno____doc__rrr!r&__static_attributes__r rrr r s@ :rr cl\rSrSrSrSSjrSrSrSrSr S r S r S r S r S rSrSrSrSrg)ConditionPoller5zA poller for CloudRun resource creation or update. Takes in a reference to a StagedProgressTracker, and updates it with progress. Nc`UVs0sH oU[5_M snUlUbJUHDnX5Vs1sH$nXb;dM URU5(aM"UiM& snURU'MF XlX l[ R UlX@lUR5 gs snfs snf)aInitialize the ConditionPoller. Start any unblocked stages in the tracker immediately. Arguments: resource_getter: function, returns a resource with conditions. tracker: a StagedProgressTracker to keep updated. It must contain a stage for each condition in the dependencies map, if the dependencies map is provided. The stage represented by each key can only start when the set of conditions in the corresponding value have all completed. If a condition should be managed by this ConditionPoller but depends on nothing, it should map to an empty set. Conditions in the tracker but *not* managed by the ConditionPoller should not appear in the dict. dependencies: Dict[str, Set[str]], The dependencies between conditions that are managed by this ConditionPoller. The values are the set of conditions that must become true before the key begins being worked on by the server. If the entire dependencies dict is None, the poller will assume that all keys in the tracker are relevant and none have dependencies. ready_message: str, message to display in header of tracker when conditions are ready. N) set _dependencies IsComplete_resource_getter_trackerrError_resource_fail_type_ready_message_StartUnblocked)rresource_gettertracker dependencies ready_messagekcs rrConditionPoller.__init__;s6-44GqSU(G4D! "_! $| $+$6$6q$9 $! 1,M)//D'5 ! sB& B+B+B+cJXR;=(a URU$r )r3)r conditions r _IsBlockedConditionPoller._IsBlockedfs! ** * Lt/A/A)/LLrc*UcgUR5$)z~Overrides. Args: conditions: A condition.Conditions object. Returns: a bool indicates whether `conditions` is terminal. F) IsTerminalrrs rrConditionPoller.IsDoneis   ""rc$UR5H|nX0R;aMXSnXSnURX4U5 UcM9U(a+URX45(aUR X5 gMkUR X45 M~ g)Nmessager)TerminalSubconditionsr3_PossiblyUpdateMessage_PossiblyCompleteStage_PollTerminalSubconditions_PossiblyFailStage)rrconditions_messagerCrKrs rrO*ConditionPoller._PollTerminalSubconditionsvs557 ,, ,%i0g$X.f !!)6HI    & &y : :  ) )* I  ;  3!8rclUR5nUbUR5(dgUR5nURR U5 UR X#5 UR 5nUR5(abURR UR5 X@R;aURUS5 URR5 U$UR5(a2X@R;aURUS5 URU5eU$)zOverrides. Args: unused_ref: A string representing the operation reference. Currently it must be 'deploy'. Returns: A condition.Conditions object. N) GetConditionsIsFreshDescriptiveMessager6UpdateHeaderMessagerOTerminalConditionIsReadyr9r3rNTickIsFailedrPr8)r unused_refrrQterminal_conditions rr&ConditionPoller.Polls ##%J!3!3!5!5 #668MM%%&89##JC#557 mm''(;(;< 11 1 ##$6= mm       11 1  2D9  $ $%7 88 rc"UR5$r )r5)rs r GetResourceConditionPoller.GetResources  ""rcXR;d URRU5(agURU5(agX#:waURRX5 gg)zUpdate the stage message. Args: condition: str, The name of the status condition. message: str, The new message to display conditions_message: str, The message from the conditions object we're displaying.. N)r6r4rD UpdateStage)rrCrKrQs rrM&ConditionPoller._PossiblyUpdateMessagesT %)A)A))L)L  y!! $ mm 3%rchURR5HnURU5 M g)zCTake care of the internal-to-this-class bookkeeping stage complete.N)r3valuesdiscard)rrC requirementss r_RecordConditionComplete(ConditionPoller._RecordConditionCompletes+ **113 9%4rcXR;d URRU5(agURRU5(dgURU5 UR 5 URR X5 g)a<Complete the stage if it's not already complete. Make sure the necessary internal bookkeeping is done. Args: condition: str, The name of the condition whose stage should be completed. message: str, The detailed message for the condition. Returns: bool: True if stage was completed, False if no action taken FT)r6r4 IsRunningrir: CompleteStagerrCrKs rrN&ConditionPoller._PossiblyCompleteStagesn %)A)A))L)L  == " "9 - - !!),MM 3 rc*URHinXR;aMURRU5(dM6URU5(aMNURR U5 Mk URR 5 g)zCall StartStage in the tracker for any not-started not-blocked tasks. Record the fact that they're started in our internal bookkeeping. N)r3r6 IsWaitingrD StartStagerZ)rr@s rr:ConditionPoller._StartUnblockedsh   --    # #DOOA,>,>   #   MMrcXR;d URRU5(agURRXRU5U5 g)zPossibly fail the stage. Args: condition: str, The name of the status whose stage failed. message: str, The detailed message for the condition. Raises: DeploymentFailedError: If the 'Ready' condition failed. N)r6r4 FailStager8rns rrP"ConditionPoller._PossiblyFailStagesG %)A)A))L)L MM++G4grcU$)zOverrides. Get terminal conditions as the polling result. Args: conditions: A condition.Conditions object. Returns: A condition.Conditions object. r rHs rr!ConditionPoller.GetResults  rcBUR5nUcgUR$zlReturns the resource conditions wrapped in condition.Conditions. Returns: A condition.Conditions object. N)r5r)rresources rrTConditionPoller.GetConditionss' $$&H    r)r3r9r8r5r6)NzDone.)r(r)r*r+r,rrDrrOr&r`rMrirNr:rPr!rTr-r rrr/r/5sR HO)VM #4&B#4$&4 $  rr/c0^\rSrSrSrSU4SjjrSrU=r$)ServiceConditionPollerizA ConditionPoller for services.cP>[TU]XU5 [RUlgr superrserverless_exceptionsDeploymentFailedErrorr8)rgetterr<r=serv __class__s rrServiceConditionPoller.__init__   GVl34JJDrr8NNr(r)r*r+r,rr- __classcell__rs@rr~r~s'KKrr~c0^\rSrSrSrSU4SjjrSrU=r$)WorkerPoolConditionPolleri%z#A ConditionPoller for worker pools.cP>[TU]XU5 [RUlgr r)rrr<r= worker_poolrs rr"WorkerPoolConditionPoller.__init__(rrrrrrs@rrr%s+KKrrc0\rSrSrSrSrSrSrSrSr g) RevisionNameBasedPolleri-z3Poll for the revision with the given name to exist.cXlX lgr  _operations_revision_ref_getter)r operationsrevision_ref_getters rr RevisionNameBasedPoller.__init__0s! 3rc[U5$r boolr revision_objs rrRevisionNameBasedPoller.IsDone4s  rcZURU5nURRU5$r )rr GetRevision)r revision_name revision_refs rr&RevisionNameBasedPoller.Poll7s),,];L    ' ' 55rcU$r r rs rr!!RevisionNameBasedPoller.GetResult;s rrN r(r)r*r+r,rrr&r!r-r rrrr-s;46rrc0\rSrSrSrSrSrSrSrSr g) NonceBasedRevisionPolleri?z@To poll for exactly one revision with the given nonce to appear.cXlX lgr )r _namespace)rr namespace_refs rr!NonceBasedRevisionPoller.__init__Bs !#Orc[U5$r rr revisionss rrNonceBasedRevisionPoller.IsDoneFs  ?rcNURRURU5$r )rGetRevisionsByNoncer)rnonces rr&NonceBasedRevisionPoller.PollIs    / / GGrc,[U5S:XaUS$g)Nr)lenrs rr!"NonceBasedRevisionPoller.GetResultLs 9~ q\ r)rrNrr rrrr?sH$Hrrc<^\rSrSrSrSU4SjjrSrSrSrU=r $)ExecutionConditionPolleriRzA ConditionPoller for jobs.c\>[TU]XU5 [RUlX0lgr )rrrExecutionFailedErrorr8_terminal_condition)rrr<r]r=rs rr!ExecutionConditionPoller.__init__Us& GVl34IID1rcUR5nX0R;dURU5(agURRUSR UR R =(d SUR55 g)zMMaybe update the terminal condition stage message with number of completions.Nz{} / {} completer)rXr6rDrcformatrsucceededCount task_count)rjob_objrr]s r%_PotentiallyUpdateInstanceCompletions>ExecutionConditionPoller._PotentiallyUpdateInstanceCompletionsZsp#557.$//33 MM!! NN ) ) .Q0B0B rcUR5nUcgURUR5nURX5 U$rz)r5rTrr)rrrs rrT&ExecutionConditionPoller.GetConditionsisF ##%G &&t'?'?@J ..wC r)r8rr ) r(r)r*r+r,rrrTr-rrs@rrrRs#2 rrc2^\rSrSrSrU4SjrSrSrU=r$)WaitOperationPolleriz[TU]"U0UD6 Xlgr )rr_messages_module)rmessages_moduleargskwargsrs rrWaitOperationPoller.__init__s Gd%f%+rcURRS5nURRSS9nURR U"UR 5US95$)zrOverrides. Args: operation_ref: googlecloudsdk.core.resources.Resource. Returns: fetched operation message. Wait10s)timeout)name%googleLongrunningWaitOperationRequest)operation_serviceGetRequestTyper%GoogleLongrunningWaitOperationRequestr RelativeName)r operation_ref request_typewait_reqs rr&WaitOperationPoller.Pollsk))88@L$$JJKH  ! ! & &++-2:  r)r) r(r)r*r+r,rr&r-rrs@rrrsD,rrN)r, __future__rrrrgooglecloudsdk.api_lib.utilrgooglecloudsdk.command_lib.runrrgooglecloudsdk.coreOperationPollerr r/r~rrrrCloudOperationPollerrr rrrs")&%'.N*:(>(>:0ef,,ePK_KKKf44$v55&++\&55r