~SrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J r SSK J r SS K Jr S rS rS rS rSrSrSrSrSrSr/r"SS\R45rSSjrSSjr"SS\5r"SS\5r g)z.Utilities for Cloud Pub/Sub Subscriptions API.)absolute_import)division)unicode_literals) list_pager)utils)apis)iam_util) exceptions20zX-Server-Timeoutdefaultneverclearc\rSrSrSrSrg)NoFieldsSpecifiedError)z:Error when no fields were specified for a Patch operation.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r2lib/googlecloudsdk/api_lib/pubsub/subscriptions.pyrr)sBrrc.[R"SSUS9$)Npubsubv1no_http)rGetClientInstancers rr r -s  $ @@rNc@U=(d [5nUR$N)r MESSAGES_MODULE)clients rGetMessagesModuler%1s  (&(&   rc\rSrSrSrSrSrg)_SubscriptionUpdateSetting6z1Data container class for updating a subscription.cXlX lgr" field_namevalue)selfr+r,s r__init__#_SubscriptionUpdateSetting.__init__9s  OJrr*N)rrrrrr.rrrrr'r'6s 9rr'cn\rSrSrSrS!SjrSrSrS"SjrSr S#S jr S r S r S$S jr S!S jrSrSrSrSrSrSrSrSrSrSrSrSrSrS%SjrSrSrSrSr S r!g)&SubscriptionsClient>z:Client for subscriptions service in the Cloud Pub/Sub API.NcU=(d [5UlU=(d [U5UlURRUlgr")r r$r%messagesprojects_subscriptions_service)r-r$r4s rr.SubscriptionsClient.__init__As5/-/DK9 1& 9DMKK66DMrcURRURRUS9UR5S9nURR U5$)zAcknowledges one or messages for a Subscription. Args: ack_ids (list[str]): List of ack ids for the messages being ack'd. subscription_ref (Resource): Relative name of the subscription for which to ack messages for. Returns: None: )ackIds)acknowledgeRequest subscription)r4-PubsubProjectsSubscriptionsAcknowledgeRequestAcknowledgeRequest RelativeNamer6 Acknowledge)r-ack_idssubscription_refack_reqs rAckSubscriptionsClient.AckFsVmmII==;;7;K%224JG == $ $W --rcURRUR5S9nURR U5$)zGets a Subscription from the API. Args: subscription_ref (Resource): Relative name of the subscription to get. Returns: Subscription: the subscription. r;)r4%PubsubProjectsSubscriptionsGetRequestr>r6Get)r-rAget_reqs rrHSubscriptionsClient.GetXsAmmAA%224BG ==  W %%rc'URRUR5UR5UUUUUURX5U U UR X5UR X5UUR UUUUUU5URUUUUUUUUUU U!5 URU"U#5S9n'U$(a2[R"URRU$U&5U'l U%(aU%U'lUR&R)U'5$![R[R[R4a"n([R "U(54U(leSn(A(ff=f)a$Creates a Subscription. Args: subscription_ref (Resource): Resource reference for subscription to be created. topic_ref (Resource): Resource reference for the associated topic for the subscriptions. ack_deadline (int): Number of seconds the system will wait for a subscriber to ack a message. push_config (Message): Message containing the push endpoint for the subscription. retain_acked_messages (bool): Whether or not to retain acked messages. message_retention_duration (int): How long to retained unacked messages. labels (Subscriptions.LabelsValue): The labels for the request. no_expiration (bool): Whether or not to set no expiration on subscription. expiration_period (str): TTL on expiration_policy. enable_message_ordering (bool): Whether or not to deliver messages with the same ordering key in order. filter_string (str): filter string in the Cloud Pub/Sub filter language. dead_letter_topic (str): Topic for publishing dead messages. max_delivery_attempts (int): Threshold of failed deliveries before sending message to the dead letter topic. min_retry_delay (str): The minimum delay between consecutive deliveries of a given message. max_retry_delay (str): The maximum delay between consecutive deliveries of a given message. enable_exactly_once_delivery (bool): Whether or not to set exactly once delivery on the subscription. bigquery_table (str): BigQuery table to which to write use_topic_schema (bool): Whether or not to use the topic schema when writing to BigQuery use_table_schema (bool): Whether or not to use the table schema when writing to BigQuery write_metadata (bool): Whether or not to write metadata fields when writing to BigQuery drop_unknown_fields (bool): Whether or not to drop fields that are only in the topic schema when writing to BigQuery bigquery_service_account_email (str): The service account to use when writing to BigQuery cloud_storage_bucket (str): The name for the Cloud Storage bucket. cloud_storage_file_prefix (str): The prefix for Cloud Storage filename. cloud_storage_file_suffix (str): The suffix for Cloud Storage filename. cloud_storage_file_datetime_format (str): The custom datetime format string for Cloud Storage filename. cloud_storage_max_bytes (int): The maximum bytes that can be written to a Cloud Storage file before a new file is created. cloud_storage_max_duration (str): The maximum duration that can elapse before a new Cloud Storage file is created. cloud_storage_max_messages (int): The maximum number of messages that can be written to a Cloud Storage file before a new file is created. cloud_storage_output_format (str): The output format for data written to Cloud Storage. cloud_storage_use_topic_schema (bool): Whether or not to use the topic schema when writing to Cloud Storage. cloud_storage_write_metadata (bool): Whether or not to write the subscription name and other metadata in the output. cloud_storage_service_account_email (str): The service account to use when writing to Cloud Storage pubsub_export_topic (str): The Pubsub topic to which to publish messages. pubsub_export_topic_region (str): The Cloud region to which to publish messages. message_transforms_file (str): The file path to the JSON or YAML file containing the message transforms. tags (TagsValue): The tags Keys/Values to be bound to the subscription. enable_vertex_ai_smt (bool): Whether or not to enable Vertex AI message transforms. Returns: Subscription: the created subscription )nametopicackDeadlineSeconds pushConfigretainAckedMessageslabelsmessageRetentionDurationexpirationPolicyenableMessageOrderingfilterdeadLetterPolicy retryPolicyenableExactlyOnceDeliverybigqueryConfigcloudStorageConfigpubsubExportConfigN)r4 Subscriptionr>_ExpirationPolicy_DeadLetterPolicy _RetryPolicy_BigQueryConfig_CloudStorageConfig_PubsubExportConfigrGetMessageTransformsFromFileMessageTransformmessageTransforms#MessageTransformsInvalidFormatErrorMessageTransformsEmptyFileError!MessageTransformsMissingFileErrorGetErrorMessageargstagsr6Create))r-rA topic_ref ack_deadline push_configretain_acked_messagesmessage_retention_durationrQ no_expirationexpiration_periodenable_message_ordering filter_stringdead_letter_topicmax_delivery_attemptsmin_retry_delaymax_retry_delayenable_exactly_once_deliverybigquery_tableuse_topic_schemause_table_schemawrite_metadatadrop_unknown_fieldsbigquery_service_account_emailcloud_storage_bucketcloud_storage_file_prefixcloud_storage_file_suffix"cloud_storage_file_datetime_formatcloud_storage_max_bytescloud_storage_max_durationcloud_storage_max_messagescloud_storage_output_formatcloud_storage_use_topic_schemacloud_storage_write_metadata#cloud_storage_service_account_emailpubsub_export_topicpubsub_export_topic_regionmessage_transforms_filerkenable_vertex_ai_smtr;es) rrlSubscriptionsClient.Creategs^==--  * * ,$$&'1!;//  6//  %%oG">++      *   33 % % . # & & ' * ( /   33 !; O.*LV ).)K)K MM * * # * & l ==   --  3 3  / /  1 1 ''*, s71D3E&E!!E&cURRUR5S9nURR U5$)zDeletes a Subscription. Args: subscription_ref (Resource): Resource reference for subscription to be deleted. Returns: None: rF)r4(PubsubProjectsSubscriptionsDeleteRequestr>r6Delete)r-rA delete_reqs rrSubscriptionsClient.DeletesAGG%224HJ ==   ++rcURRUR5US9n[R"UR UUSSS9$)a2Lists Subscriptions for a given project. Args: project_ref (Resource): Resource reference to Project to list subscriptions from. page_size (int): the number of entries in each batch (affects requests made, but not the yielded results). Returns: A generator of subscriptions in the project. )projectpageSize subscriptionsr) batch_sizefieldbatch_size_attribute)r4&PubsubProjectsSubscriptionsListRequestr>r YieldFromListr6)r- project_ref page_sizelist_reqs rListSubscriptionsClient.List$sT}}CC((*YDH  # # '  rcURRURRX2S9UR5S9nURR U5$)aModifies the ack deadline for messages for a Subscription. Args: subscription_ref (Resource): Resource reference for subscription to be modified. ack_ids (list[str]): List of ack ids to modify. ack_deadline (int): The new ack deadline for the messages. Returns: None: )rNr9)modifyAckDeadlineRequestr;)r43PubsubProjectsSubscriptionsModifyAckDeadlineRequestModifyAckDeadlineRequestr>r6ModifyAckDeadline)r-rAr@rnmod_reqs rr%SubscriptionsClient.ModifyAckDeadline;s^mmOO!%!G!G+"H" &224 PG == * *7 33rcURRURRUS9UR5S9nURR U5$)zModifies the push endpoint for a Subscription. Args: subscription_ref (Resource): Resource reference for subscription to be modified. push_config (Message): The new push endpoint for the Subscription. Returns: None: )rO)modifyPushConfigRequestr;)r42PubsubProjectsSubscriptionsModifyPushConfigRequestModifyPushConfigRequestr>r6ModifyPushConfig)r-rArors rr$SubscriptionsClient.ModifyPushConfigPs^mmNN $ E E"!F! &224 OG == ) )' 22rc2URRURRX#S9UR5S9n[UR R ['URRU5nUR R [ U$)aPulls one or more messages from a Subscription. Args: subscription_ref (Resource): Resource reference for subscription to be pulled from. max_messages (int): The maximum number of messages to retrieve. return_immediately (bool): Whether or not to return immediately without waiting for a new message for a bounded amount of time if there is nothing to pull right now. Returns: PullResponse: proto containing the received messages. ) maxMessagesreturnImmediately) pullRequestr;) r4&PubsubProjectsSubscriptionsPullRequest PullRequestr>PULL_RPC_DEADLINE_SECONDSr$additional_http_headersSERVER_TIMEOUT_HEADERr6Pull)r-rA max_messagesreturn_immediatelypull_req pull_resps rrSubscriptionsClient.Pullcs}}CCMM--$. &224 DH " KK''(=> ""8,I ++,AB rcU=(a UR5nURRURRXBS9UR5S9nURR U5$)aReset a Subscription's backlog to point to a given time or snapshot. Args: subscription_ref (Resource): Resource reference for subscription to be seeked on. time (str): The time to reset to. snapshot_ref (Resource): Resource reference to a snapshot.. Returns: None: )snapshottime) seekRequestr;)r>r4&PubsubProjectsSubscriptionsSeekRequest SeekRequestr6Seek)r-rAr snapshot_refrseek_reqs rrSubscriptionsClient.Seek~si; 9 9 ;H}}CCMM--x-K%224DH ==  h ''rcU(aURRSS9$U(aURRUS9$g)zBuild ExpirationPolicy message from argument values. Args: no_expiration (bool): Whether or not to set no expiration on subscription. expiration_period (str): TTL on expiration_policy. Returns: ExpirationPolicy message or None. N)ttl)r4ExpirationPolicy)r-rrrss rr]%SubscriptionsClient._ExpirationPolicys> ]] + + + 55 ]] + +0A + BB rcFU(aURRUUS9$g)aBuilds DeadLetterPolicy message from argument values. Args: dead_letter_topic (str): Topic for publishing dead messages. max_delivery_attempts (int): Threshold of failed deliveries before sending message to the dead letter topic. Returns: DeadLetterPolicy message or None. )deadLetterTopicmaxDeliveryAttemptsN)r4DeadLetterPolicy)r-rvrws rr^%SubscriptionsClient._DeadLetterPolicys. ]] + ++3, rcRU(dU(aURRXS9$g)a*Builds RetryPolicy message from argument values. Args: min_retry_delay (str): The minimum delay between consecutive deliveries of a given message. max_retry_delay (str): The maximum delay between consecutive deliveries of a given message. Returns: DeadLetterPolicy message or None. )minimumBackoffmaximumBackoffN)r4 RetryPolicy)r-rxrys rr_ SubscriptionsClient._RetryPolicys-/ ]] & &(' rc NU(aURRUUUUUUS9$g)aBuilds BigQueryConfig message from argument values. Args: table (str): The name of the table use_topic_schema (bool): Whether or not to use the topic schema use_table_schema (bool): Whether or not to use the table schema write_metadata (bool): Whether or not to write metadata fields drop_unknown_fields (bool): Whether or not to drop fields that are only in the topic schema service_account_email(str): The service account to use Returns: BigQueryConfig message or None )tableuseTopicSchemauseTableSchema writeMetadatadropUnknownFieldsserviceAccountEmailN)r4BigQueryConfig)r-rr|r}r~rservice_account_emails rr`#SubscriptionsClient._BigQueryConfigs:. ]] ) )))&/3 * rc U(aURRUUUUUUUU S9n US:Xa!URR5U lU $US:Xa1URR U (aU OSU (aU OSS9U lU $g)a5Builds CloudStorageConfig message from argument values. Args: bucket (str): The name for the Cloud Storage bucket. file_prefix (str): The prefix for Cloud Storage filename. file_suffix (str): The suffix for Cloud Storage filename. file_datetime_format (str): The custom datetime format string for Cloud Storage filename. max_bytes (int): The maximum bytes that can be written to a Cloud Storage file before a new file is created. max_duration (str): The maximum duration that can elapse before a new Cloud Storage file is created. max_messages (int): The maximum number of messages that can be written to a Cloud Storage file before a new file is created. output_format (str): The output format for data written to Cloud Storage. use_topic_schema (bool): Whether or not to use the topic schema when writing to Cloud Storage. write_metadata (bool): Whether or not to write the subscription name and other metadata in the output. service_account_email(str): The service account to use Returns: CloudStorageConfig message or None )bucketfilenamePrefixfilenameSuffixfilenameDatetimeFormatmaxBytes maxDurationrrtextavroFN)rr)r4CloudStorageConfig TextConfig textConfig AvroConfig avroConfig) r-r file_prefix file_suffixfile_datetime_format max_bytes max_durationr output_formatr|r~rcloud_storage_configs rra'SubscriptionsClient._CloudStorageConfigsL!]]==$$!5""3>  & *.--*B*B*D'"! F "*.--*B*B,:.0@+T +C+ ' "! rcDU(aURRXS9$g)zBuilds PubsubExportConfig message from argument values. Args: topic (str): The Pubsub topic to which to publish messages. region (str): The Cloud region to which to publish messages. Returns: PubsubExportConfig message or None )rMregionN)r4PubSubExportConfig)r-rMrs rrb'SubscriptionsClient._PubsubExportConfig%s" ]] - -E - II rc<UR[:XaSUlggr")r,DEFAULT_MESSAGE_RETENTION_VALUEr-update_settings r_HandleMessageRetentionUpdate1SubscriptionsClient._HandleMessageRetentionUpdate3s>>!n?rc<UR[:XaSUlggr")r,CLEAR_DEAD_LETTER_VALUErs r_HandleDeadLetterPolicyUpdate1SubscriptionsClient._HandleDeadLetterPolicyUpdate7s66!n7rc<UR[:XaSUlggr")r,CLEAR_RETRY_VALUErs r_HandleRetryPolicyUpdate,SubscriptionsClient._HandleRetryPolicyUpdate;s00!n1rc<UR[:XaSUlggr")r,CLEAR_BIGQUERY_CONFIG_VALUErs r_HandleBigQueryConfigUpdate/SubscriptionsClient._HandleBigQueryConfigUpdate?s::!n;rc<UR[:XaSUlggr")r, CLEAR_CLOUD_STORAGE_CONFIG_VALUErs r_HandleCloudStorageConfigUpdate3SubscriptionsClient._HandleCloudStorageConfigUpdateC??!n@rc<UR[:XaSUlggr")r,"CLEAR_PUSH_NO_WRAPPER_CONFIG_VALUErs r_HandlePushNoWrapperUpdate.SubscriptionsClient._HandlePushNoWrapperUpdateGsAA!nBrc<UR[:XaSUlggr")r, CLEAR_PUBSUB_EXPORT_CONFIG_VALUErs r_HandlePubsubExportConfigUpdate3SubscriptionsClient._HandlePubsubExportConfigUpdateKrrc*(U"(a[n*OURUUUUUUUUUU U!5 n*U (a[n+OURX5n+U(a[n,OUR X5n,U(a[ n-OURUUUUUU5n-U&(a[n.OURU$U%5n.U#(a[n/OSn/U'(a.[R"URRU'U)5n0OSn0U((a[(n2OSn2[+SU5[+SU5[+SU5[+SU5[+SU5[+SU5[+SUR-Xx55[+S U+5[+S U,5[+S U-5[+S U*5[+S U/5[+SU.5[+SU05[+SU25/n3URR/UR15S9n4/n5U3GHWn6U6R2cMU6R4S:XaUR7U65 U6R4S :XaUR9U65 U6R4S :XaUR;U65 U6R4S :XaUR=U65 U6R4S :XaUR?U65 U6R4S:XaURAU65 U6R4S :Xa2URCU65 UcU5REU6R45 GMU4U6R4U6R25 U5REU6R45 GMZ U5(d [IS5eURRKURRMU4SROU55S9UR15S9n7URPRSU75$![R[R [R"4a"n1[R$"U154U1leSn1A1ff=f)aUpdates a Subscription. Args: subscription_ref (Resource): Resource reference for subscription to be updated. ack_deadline (int): Number of seconds the system will wait for a subscriber to ack a message. push_config (Message): Message containing the push endpoint for the subscription. retain_acked_messages (bool): Whether or not to retain acked messages. message_retention_duration (str): How long to retained unacked messages. labels (LabelsValue): The Cloud labels for the subscription. no_expiration (bool): Whether or not to set no expiration on subscription. expiration_period (str): TTL on expiration_policy. dead_letter_topic (str): Topic for publishing dead messages. max_delivery_attempts (int): Threshold of failed deliveries before sending message to the dead letter topic. clear_dead_letter_policy (bool): If set, clear the dead letter policy from the subscription. min_retry_delay (str): The minimum delay between consecutive deliveries of a given message. max_retry_delay (str): The maximum delay between consecutive deliveries of a given message. clear_retry_policy (bool): If set, clear the retry policy from the subscription. enable_exactly_once_delivery (bool): Whether or not to set exactly once delivery on the subscription. bigquery_table (str): BigQuery table to which to write use_topic_schema (bool): Whether or not to use the topic schema when writing to BigQuery use_table_schema (bool): Whether or not to use the table schema when writing to BigQuery write_metadata (bool): Whether or not to write metadata fields when writing to BigQuery drop_unknown_fields (bool): Whether or not to drop fields that are only in the topic schema when writing to BigQuery bigquery_service_account_email (str): The service account to use when writing to BigQuery clear_bigquery_config (bool): If set, clear the BigQuery config from the subscription cloud_storage_bucket (bool): The name for the Cloud Storage bucket. cloud_storage_file_prefix (str): The prefix for Cloud Storage filename. cloud_storage_file_suffix (str): The suffix for Cloud Storage filename. cloud_storage_file_datetime_format (str): The custom datetime format string for Cloud Storage filename. cloud_storage_max_bytes (int): The maximum bytes that can be written to a Cloud Storage file before a new file is created. cloud_storage_max_duration (str): The maximum duration that can elapse before a new Cloud Storage file is created. cloud_storage_max_messages (int): The maximum number of messages that can be written to a Cloud Storage file before a new file is created. cloud_storage_output_format (str): The output format for data written to Cloud Storage. cloud_storage_use_topic_schema (bool): Whether or not to use the topic schema when writing to Cloud Storage. cloud_storage_write_metadata (bool): Whether or not to write the subscription name and other metadata in the output. cloud_storage_service_account_email (str): The service account to use when writing to Cloud Storage clear_cloud_storage_config (bool): If set, clear the Cloud Storage config from the subscription. clear_push_no_wrapper_config (bool): If set, clear the Push No Wrapper config from the subscription. pubsub_export_topic (str): The Pubsub topic to which to publish messages. pubsub_export_topic_region (str): The Cloud region to which to publish messages. clear_pubsub_export_config (bool): If set, clear the Pubsub export config from the subscription. message_transforms_file (str): The file path to the JSON or YAML file containing the message transforms. clear_message_transforms (bool): If set, clears all message transforms from the subscription. enable_vertex_ai_smt (bool): If set, enables Vertex AI message transforms. Returns: Subscription: The updated subscription. Raises: NoFieldsSpecifiedError: if no fields were specified. NrNrOrPrXrRrQrSrVrWrYrZzpushConfig.noWrapperr[re)rLz*Must specify at least one field to update.,)r; updateMask)updateSubscriptionRequestrL)*rrarr^rr_r r`rrbrrrcr4rdrfrgrhrirj#CLEAR_MESSAGE_TRANSFORMATIONS_VALUEr'r]r\r>r,r+rrr r rrrappendsetattrr'PubsubProjectsSubscriptionsPatchRequestUpdateSubscriptionRequestjoinr6Patch)8r-rArnrorprqrQrrrsrvrwclear_dead_letter_policyrxryclear_retry_policyrzr{r|r}r~rrclear_bigquery_configrrrrrrrrrrrclear_cloud_storage_configclear_push_no_wrapper_configrrclear_pubsub_export_configrclear_message_transformsrcloud_storage_config_settingsdead_letter_policy retry_policybigquery_configpubsub_export_configpush_config_no_wrappermessage_transformsrclear_messagesupdate_settingsr; update_maskr patch_reqs8 rr&SubscriptionsClient.PatchOsx"&F#&*&>&>  # # , ! $ $ % ( & - '# 211 &l&&Hl3o,,      ( o"=!55 9$A# "?? MM * * #   :nn ##7F"<=" !#8  # ')E  # &(B  #8V4"   " "= D  ##57IJ"=,?"#3_E" "?  # "$:  ##79MN"#68JK"#6G9O<==--  * * ,.LK)    )  $ $(B B  , ,^ <  $ $(: :  , ,^ <  $ $ 5  ' ' 7  $ $(8 8  * *> :  $ $(< <  . .~ >  $ $(< <  . .~ >  $ $(> >  ) ). 9    ~88 9  n779M9MN>445)**  "#O PP EE"&--"I"I%#((;2G#J#  * * , FI ==  y ))]  3 3  / /  1 1 ''*, s,N<<3P/P  PcURRUR5URRUS9S9nURR U5$)zSets an IAM policy on a Subscription. Args: subscription_ref (Resource): Resource reference for subscription to set IAM policy on. policy (Policy): The policy to be added to the Subscription. Returns: Policy: the policy which was set. )policy)resourcesetIamPolicyRequest)r4.PubsubProjectsSubscriptionsSetIamPolicyRequestr>SetIamPolicyRequestr6 SetIamPolicy)r-rAr;requests rr@ SubscriptionsClient.SetIamPolicyXsVmmJJ!..0 MM==V=LKG == % %g ..rcURRUR5S9nURR U5$)zGets the IAM policy for a Subscription. Args: subscription_ref (Resource): Resource reference for subscription to get the IAM policy of. Returns: Policy: the policy for the Subscription. )r<)r4.PubsubProjectsSubscriptionsGetIamPolicyRequestr>r6 GetIamPolicy)r-rArAs rrE SubscriptionsClient.GetIamPolicyisAmmJJ!..0KG == % %g ..rcURU5n[R"URRXBU5 UR X5$)a^Adds an IAM Policy binding to a Subscription. Args: subscription_ref (Resource): Resource reference for subscription to add IAM policy binding to. member (str): The member to add. role (str): The role to assign to the member. Returns: Policy: the updated policy. Raises: api_exception.HttpException: If either of the requests failed. )rEr AddBindingToIamPolicyr4Bindingr@r-rAmemberroler;s rAddIamPolicyBinding'SubscriptionsClient.AddIamPolicyBindingxsC  / 0F ""4==#8#8&$O   - 66rctURU5n[R"XBU5 URX5$)ahRemoves an IAM Policy binding from a Subscription. Args: subscription_ref (Resource): Resource reference for subscription to remove IAM policy binding from. member (str): The member to add. role (str): The role to assign to the member. Returns: Policy: the updated policy. Raises: api_exception.HttpException: If either of the requests failed. )rEr RemoveBindingFromIamPolicyr@rJs rRemoveIamPolicyBinding*SubscriptionsClient.RemoveIamPolicyBindings7  / 0F ''=   - 66r)r6r$r4)NN)#NNNNFNNNNNNNNNNNNNNNNNNNNNNNNNNNNNF)d)T)(NNNNNFNNNFNNFNNNNNNNFNNNNNNNNNNNFFNNFNFF)"rrrrrr.rCrHrlrrrrrrr]r^r_r`rarbrrr r rrrr&r@rErMrQrrrrr1r1>s~B7 .$ &( !% " #'%) $ $)-"!%!%"&%)#'*.!%"  Ol.\ ,.4*3&6(& $$ D<| """"""" !%  $#'%)! $ $)-"!%!%"&%)#'*.!&#(!%!&"$ UG*R/" /7$7rr1)Fr")!r __future__rrrapitools.base.pyrgooglecloudsdk.api_lib.pubsubrgooglecloudsdk.api_lib.utilrgooglecloudsdk.command_lib.iamr googlecloudsdk.corer rrrNEVER_EXPIRATION_PERIOD_VALUErrr rrrr Errorrr r%objectr'r1rrrr]s 5&''/,3*!*"+ '!%#* %,"#* &(#CZ--CA \ 7&\ 7r