ci8+ddlmZddlmZddlZej Zejdk\rddlm Z nddl Z ddl m Z ddl m Z ddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z ddlm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%ddlm&Z&ddlm'Z'ddlm(Z(dd lm)Z)dd!lm*Z*dd"lm+Z+dd#lm,Z,dd$lm-Z-dd%lm.Z.dd&lm/Z/dd'lm0Z0dd(lm1Z1dd)lm2Z2dd*lm3Z3dd+lm4Z4dd,lm5Z5dd-lm6Z6dd.lm7Z7dd/lm8Z8dd0lm9Z9dd1lm:Z:dd2lm;Z;dd3lmZ>dd6lm?Z?dd7lm@Z@dd8lmAZAdd9lmBZBdd:lmCZCdd;lmDZDddlmGZGdd?lmHZHdd@lImJZJddAlImKZKddBlImLZLddClImMZMddDlImNZNddElImOZOddFlImPZPddGlImQZQddHlImRZRddIlImSZSddJlImTZTddKlImUZUddLlImVZVddMlImWZWddNlImXZXddOlImYZYddPlImZZZe[edQr0e[edRr'ejdSejdSd~Zoy ddl^Z^ddlZejjdZadSZbejdTkr+e^jdUdVeadWzdXebdYzdZzd[ebd\zedejdd]dTk(r.e^jd^ead_d`ebdazdbzdczddzdeebd\zeddfeefdgZfdhZgdiZhdjZidkZjdlZkegeh\ZlZmelr^elejkrYe^jdmebdnehdozemdpzebdqehdrzdseidtekd\zduzdvzdwehdxzebdyzdzzd{eid|zehd\zedd~Zoy#en$re^jd}Yd~ZoywxYw)) gapic_versionN))metadata)PublisherClient)PublisherAsyncClient)SchemaServiceClient)SchemaServiceAsyncClient)SubscriberClient)SubscriberAsyncClient)AcknowledgeRequest) AIInference)BigQueryConfig)CloudStorageConfig)CreateSnapshotRequest)DeadLetterPolicy)DeleteSnapshotRequest)DeleteSubscriptionRequest)DeleteTopicRequest)DetachSubscriptionRequest)DetachSubscriptionResponse)ExpirationPolicy)GetSnapshotRequest)GetSubscriptionRequest)GetTopicRequest)IngestionDataSourceSettings)IngestionFailureEvent) JavaScriptUDF)ListSnapshotsRequest)ListSnapshotsResponse)ListSubscriptionsRequest)ListSubscriptionsResponse)ListTopicSnapshotsRequest)ListTopicSnapshotsResponse)ListTopicsRequest)ListTopicsResponse)ListTopicSubscriptionsRequest)ListTopicSubscriptionsResponse)MessageStoragePolicy)MessageTransform)ModifyAckDeadlineRequest)ModifyPushConfigRequest)PlatformLogsSettings)PublishRequest)PublishResponse) PubsubMessage) PullRequest) PullResponse) PushConfig)ReceivedMessage) RetryPolicy)SchemaSettings) SeekRequest) SeekResponse)Snapshot)StreamingPullRequest)StreamingPullResponse) Subscription)Topic)UpdateSnapshotRequest)UpdateSubscriptionRequest)UpdateTopicRequest)CommitSchemaRequest)CreateSchemaRequest)DeleteSchemaRequest)DeleteSchemaRevisionRequest)GetSchemaRequest)ListSchemaRevisionsRequest)ListSchemaRevisionsResponse)ListSchemasRequest)ListSchemasResponse)RollbackSchemaRequest)Schema)ValidateMessageRequest)ValidateMessageResponse)ValidateSchemaRequest)ValidateSchemaResponse)Encoding) SchemaViewcheck_python_versioncheck_dependency_versionszgoogle.pubsub_v1)r z-You are using a non-supported Python version (z%). Google will not post any further z updates to z! supporting this Python version. z3Please upgrade to the latest Python version, or at z%least to Python 3.9, and then update .z You are using a Python version (z) z%which Google will stop supporting in z in zJanuary 2026. Please z,upgrade to the latest Python version, or at z'least to Python 3.10, before then, and z then update version_stringcg}|jdD]} |jt|t |S#t$rYt |SwxYw)aSafely converts a semantic version string to a comparable tuple of integers. Example: "4.25.8" -> (4, 25, 8) Ignores non-numeric parts and handles common version formats. Args: version_string: Version string in the format "x.y.z" or "x.y.z" Returns: Tuple of integers for the parsed version string. rW)splitappendint ValueErrortuple)rYpartsparts @/tmp/pip-target-z3e9_cxr/lib/python/google/pubsub_v1/__init__.pyparse_version_to_tuplercsdE&,,S1 LLT+ <  "<  s? AAcj tj|}t|}||fS#t$rYywxYw)N)Nz--)rversionrc Exception)dependency_namerYparsed_versions rb _get_versionris@ $&.&6&6&G!7!G&77 $$ $s #& 22zgoogle.protobufz4.25.8)rz (we recommend 6.x)zPackage z depends on z!, currently installed at version z. Future updates to z will require z at zversion z or higherz Please ensure z8that either (a) your Python environment doesn't pin the z version of z, so that updates to z$ can require the higher version, or z:(b) you manually update your Python environment to use at zleast version z of zCould not determine the version of Python currently being used. To continue receiving updates for {_package_label}, ensure you are using a supported version of Python; see https://devguide.python.org/versions/)Kr r r rrrrrBrCrrrDrErrrrrrQrrFrrrrrrrGrHrIrJr r!r"r#r$r%r(r)r&r'r*r+r,r-r.r/r0rr1r2r3r4r5r6rKrLr r7rRr8r9r:r;r<r r=r>r?r@rArMrNrOrP)pgoogle.pubsub_v1rpackage_versiongoogle.api_coreapi_coresys __version__ version_info importlibrimportlib_metadataservices.publisherrr services.schema_servicer r services.subscriberr r types.pubsubrrrrrrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rA types.schemarBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRhasattrrSrTwarningsrer[_py_version_str_package_labelwarn FutureWarningstrrcri_dependency_package_next_supported_version_next_supported_version_tuple_recommendation _version_used_version_used_stringrf__all__rbrs >" )) v"*048=16,%(,/*/3,34*,0)5/'./2334+,78.*21.()'%&$)%(%&"./&/3,---5*45,-/ 01/0"$ 8+, )2"H!!"45&H&&'9:tL mT ++++-a0+   f $ HMM?o&&KLM//PQRHH:.9IK L      BQ 6 ) HMM2?2C2F9.9INO)*AA< < ! 02 3   3 ( $0"*(2%/0<=P0Q-, ]-JJ HMM>*,7())JKL)**>?@$$N3F2GtLM45Z?PPQR S $ $ M M 344IJK$$$HIJO O##:";4@ A))+ , 0L     6 L  s3DMM/.M/