~dZddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z dd l mZd Zd Zd Zd ZdZdZdZdZdZdZgZGddej4ZddZddZGddeZGddeZ y)z.Utilities for Cloud Pub/Sub Subscriptions API.)absolute_import)division)unicode_literals) list_pager)utils)apis)iam_util) exceptions20zX-Server-TimeoutdefaultneverclearceZdZdZy)NoFieldsSpecifiedErrorz:Error when no fields were specified for a Patch operation.N)__name__ __module__ __qualname____doc__2lib/googlecloudsdk/api_lib/pubsub/subscriptions.pyrr)sBrrc2tjdd|S)Npubsubv1no_http)rGetClientInstancers rrr-s  $ @@rNc6|xs t}|jSN)rMESSAGES_MODULE)clients rGetMessagesModuler"1s  (&(&   rceZdZdZdZy)_SubscriptionUpdateSettingz1Data container class for updating a subscription.c ||_||_yr) field_namevalue)selfr&r's r__init__z#_SubscriptionUpdateSetting.__init__9s DODJrN)rrrrr)rrrr$r$6s 9rr$cZeZdZdZddZdZdZ d dZdZd!dZ d Z d Z d"d Z dd Z d ZdZdZdZdZdZdZdZdZdZdZdZdZ d#dZdZdZdZdZy)$SubscriptionsClientz:Client for subscriptions service in the Cloud Pub/Sub API.Nc|xs t|_|xs t||_|jj|_yr)rr!r"messagesprojects_subscriptions_service)r(r!r-s rr)zSubscriptionsClient.__init__As5/-/DK9 1& 9DMKK66DMrc|jj|jj||j}|jj |S)aAcknowledges 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)r--PubsubProjectsSubscriptionsAcknowledgeRequestAcknowledgeRequest RelativeNamer/ Acknowledge)r(ack_idssubscription_refack_reqs rAckzSubscriptionsClient.AckFsVmmII==;;7;K%224JG == $ $W --rc|jj|j}|jj |S)zGets a Subscription from the API. Args: subscription_ref (Resource): Relative name of the subscription to get. Returns: Subscription: the subscription. r3)r-%PubsubProjectsSubscriptionsGetRequestr6r/Get)r(r9get_reqs rr?zSubscriptionsClient.GetXsAmmAA%224BG ==  W %%rc'|jj|j|j||||||j|| | | |j | | |j ||||j |||||||j|||||||||| |! |j|"|#}'|$r1 tj|jj|$|&|'_ |%r|%|'_|j&j)|'S#tjtjtjf$r!}(tj |(f|(_d}(~(wwxYw)a0Creates 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)r- Subscriptionr6_ExpirationPolicy_DeadLetterPolicy _RetryPolicy_BigQueryConfig_CloudStorageConfig_PubsubExportConfigrGetMessageTransformsFromFileMessageTransformmessageTransforms#MessageTransformsInvalidFormatErrorMessageTransformsEmptyFileError!MessageTransformsMissingFileErrorGetErrorMessageargstagsr/Create))r(r9 topic_ref ack_deadline push_configretain_acked_messagesmessage_retention_durationrG 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_fileraenable_vertex_ai_smtr3es) rrbzSubscriptionsClient.Creategs^==--  * * ,$$&'1!;// , 6// 4 %%oG">++      *   33 % % . # & & ' * ( /   33 !; O.*LV ).)K)K MM * * # * & l ==   --  3 3  / /  1 1 ''*, s80D 2E>EEc|jj|j}|jj |S)zDeletes a Subscription. Args: subscription_ref (Resource): Resource reference for subscription to be deleted. Returns: None: r=)r-(PubsubProjectsSubscriptionsDeleteRequestr6r/Delete)r(r9 delete_reqs rrzSubscriptionsClient.DeletesAGG%224HJ ==   ++rc|jj|j|}tj|j ||ddS)aRLists 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)r-&PubsubProjectsSubscriptionsListRequestr6r YieldFromListr/)r( project_ref page_sizelist_reqs rListzSubscriptionsClient.List$sT}}CC((*YDH  # # '  rc|jj|jj|||j}|jj |S)a:Modifies 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: )rDr1)modifyAckDeadlineRequestr3)r-3PubsubProjectsSubscriptionsModifyAckDeadlineRequestModifyAckDeadlineRequestr6r/ModifyAckDeadline)r(r9r8rdmod_reqs rrz%SubscriptionsClient.ModifyAckDeadline;s`mmOO!%!G!G+G"H" &224 PG == * *7 33rc|jj|jj||j}|jj |S)aModifies 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: )rE)modifyPushConfigRequestr3)r-2PubsubProjectsSubscriptionsModifyPushConfigRequestModifyPushConfigRequestr6r/ModifyPushConfig)r(r9rers rrz$SubscriptionsClient.ModifyPushConfigPs^mmNN $ E E"!F! &224 OG == ) )' 22rc@|jj|jj|||j}t|j j t<|jj|}|j j t=|S)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) pullRequestr3) r-&PubsubProjectsSubscriptionsPullRequest PullRequestr6PULL_RPC_DEADLINE_SECONDSr!additional_http_headersSERVER_TIMEOUT_HEADERr/Pull)r(r9 max_messagesreturn_immediatelypull_req pull_resps rrzSubscriptionsClient.Pullcs}}CCMM--$8J. &224 DH " KK''(=> ""8,I ++,AB rc|xr|j}|jj|jj|||j}|jj |S)a8Reset 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) seekRequestr3)r6r-&PubsubProjectsSubscriptionsSeekRequest SeekRequestr/Seek)r(r9r snapshot_refrseek_reqs rrzSubscriptionsClient.Seek~sk; 9 9 ;H}}CCMM--xd-K%224DH ==  h ''rc||r|jjdS|r|jj|Sy)aBuild 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)r-ExpirationPolicy)r(rhris rrSz%SubscriptionsClient._ExpirationPolicys> ]] + + + 55 ]] + +0A + BB rcB|r|jj||Sy)a9Builds 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)r-DeadLetterPolicy)r(rlrms rrTz%SubscriptionsClient._DeadLetterPolicys. ]] + ++3, rcF|s|r|jj||Sy)aJBuilds 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)r- RetryPolicy)r(rnros rrUz SubscriptionsClient._RetryPolicys// ]] & &(' rcJ|r!|jj||||||Sy)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)r-BigQueryConfig)r(rrrrsrtruservice_account_emails rrVz#SubscriptionsClient._BigQueryConfigs:. ]] ) )))&/3 * rc |rz|jj|||||||| } |dk(r!|jj| _| S|dk(r*|jj | r| nd| r| nd| _| Sy)aBuilds 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)r-CloudStorageConfig TextConfig textConfig AvroConfig avroConfig) r(r file_prefix file_suffixfile_datetime_format max_bytes max_durationr output_formatrrrtrcloud_storage_configs rrWz'SubscriptionsClient._CloudStorageConfigsL!]]==$$!5""3>  & *.--*B*B*D'"! F "*.--*B*B,:.0@+T +C+ ' "! rcB|r|jj||Sy)aBuilds 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 )rCregionN)r-PubSubExportConfig)r(rCrs rrXz'SubscriptionsClient._PubsubExportConfig%s$ ]] - -E& - II rc:|jtk(rd|_yyr)r'DEFAULT_MESSAGE_RETENTION_VALUEr(update_settings r_HandleMessageRetentionUpdatez1SubscriptionsClient._HandleMessageRetentionUpdate3s>>!n?rc:|jtk(rd|_yyr)r'CLEAR_DEAD_LETTER_VALUErs r_HandleDeadLetterPolicyUpdatez1SubscriptionsClient._HandleDeadLetterPolicyUpdate7s66!n7rc:|jtk(rd|_yyr)r'CLEAR_RETRY_VALUErs r_HandleRetryPolicyUpdatez,SubscriptionsClient._HandleRetryPolicyUpdate;s00!n1rc:|jtk(rd|_yyr)r'CLEAR_BIGQUERY_CONFIG_VALUErs r_HandleBigQueryConfigUpdatez/SubscriptionsClient._HandleBigQueryConfigUpdate?s::!n;rc:|jtk(rd|_yyr)r' CLEAR_CLOUD_STORAGE_CONFIG_VALUErs r_HandleCloudStorageConfigUpdatez3SubscriptionsClient._HandleCloudStorageConfigUpdateC??!n@rc:|jtk(rd|_yyr)r'"CLEAR_PUSH_NO_WRAPPER_CONFIG_VALUErs r_HandlePushNoWrapperUpdatez.SubscriptionsClient._HandlePushNoWrapperUpdateGsAA!nBrc:|jtk(rd|_yyr)r' CLEAR_PUBSUB_EXPORT_CONFIG_VALUErs r_HandlePubsubExportConfigUpdatez3SubscriptionsClient._HandlePubsubExportConfigUpdateKrrc*|"rt}*n|j|||||||||| |! }*| rt}+n|j| | }+|rt},n|j | | },|rt }-n|j||||||}-|&rt}.n|j|$|%}.|#rt}/nd}/|'r- tj|jj|'|)}0nd}0|(rt(}2nd}2t+d|t+d|t+d|t+d|t+d|t+d|t+d|j-||t+d |+t+d |,t+d |-t+d |*t+d |/t+d|.t+d|0t+d|2g}3|jj/|j1}4g}5|3D]K}6|6j2|6j4dk(r|j7|6|6j4d k(r|j9|6|6j4d k(r|j;|6|6j4d k(r|j=|6|6j4d k(r|j?|6|6j4dk(r|jA|6|6j4d k(r0|jC|6||5jE|6j4tG|4|6j4|6j2|5jE|6j4N|5s tId|jjK|jjM|4djO|5|j1}7|jPjS|7S#tjtj tj"f$r!}1tj$|1f|1_d}1~1wwxYw)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. NrDrErFrNrHrGrIrLrMrOrPzpushConfig.noWrapperrQr[)rBz*Must specify at least one field to update.,)r3 updateMask)updateSubscriptionRequestrB)*rrWrrTrrUrrVrrXrrrYr-rZr\r]r^r_r`#CLEAR_MESSAGE_TRANSFORMATIONS_VALUEr$rSrRr6r'r&rrrrrrrappendsetattrr'PubsubProjectsSubscriptionsPatchRequestUpdateSubscriptionRequestjoinr/Patch)8r(r9rdrerfrgrGrhrirlrmclear_dead_letter_policyrnroclear_retry_policyrprqrrrsrtrurvclear_bigquery_configrwrxryrzr{r|r}r~rrrclear_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_settingsr3 update_maskr patch_reqs8 rrzSubscriptionsClient.PatchOs x"&F#&*&>&>  # # , ! $ $ % ( & - '# 211 2&l&&Hl3o,,      ( o"=!55 9$A# "?? MM * * #   :nn ##7F"<=" !#8  # ')E  # &(B  #8V4"   " "=2C 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 2O ?OO c|jj|j|jj|}|jj |S)aSets 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)r-.PubsubProjectsSubscriptionsSetIamPolicyRequestr6SetIamPolicyRequestr/ SetIamPolicy)r(r9rrequests rr!z SubscriptionsClient.SetIamPolicyXsVmmJJ!..0 MM==V=LKG == % %g ..rc|jj|j}|jj |S)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)r-.PubsubProjectsSubscriptionsGetIamPolicyRequestr6r/ GetIamPolicy)r(r9r"s rr%z SubscriptionsClient.GetIamPolicyisAmmJJ!..0KG == % %g ..rc|j|}tj|jj||||j ||S)aAdds 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. )r%r AddBindingToIamPolicyr-Bindingr!r(r9memberrolers rAddIamPolicyBindingz'SubscriptionsClient.AddIamPolicyBindingxsG  / 0F ""4==#8#8&&$O   -v 66rcv|j|}tj||||j||S)aRemoves 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. )r%r RemoveBindingFromIamPolicyr!r)s rRemoveIamPolicyBindingz*SubscriptionsClient.RemoveIamPolicyBindings;  / 0F ''=   -v 66r)NN)#NNNNFNNNNNNNNNNNNNNNNNNNNNNNNNNNNNF)d)T)(NNNNNFNNNFNNFNNNNNNNFNNNNNNNNNNNFFNNFNFF) rrrrr)r;r?rbrrrrrrrSrTrUrVrWrXrrrrrrrrr!r%r,r/rrrr+r+>s~B7 .$ &( !% " #'%) $ $)-"!%!%"&%)#'*.!%"  Ol.\ ,.4*3&6(& $$ D<| """"""" !%  $#'%)! $ $)-"!%!%"&%)#'*.!&#(!%!&"$ UG*R/" /7$7rr+)Fr)!r __future__rrrapitools.base.pyrgooglecloudsdk.api_lib.pubsubrgooglecloudsdk.api_lib.utilrgooglecloudsdk.command_lib.iamr googlecloudsdk.corer rrrNEVER_EXPIRATION_PERIOD_VALUErrrrrrrErrorrrr"objectr$r+rrrr:s 5&''/,3*!*"+ '!%#* %,"#* &(#CZ--CA \ 7&\ 7r