google-cloud-pubsub

Bug Fixes

• Add context manager return types (4f690b9)

Documentation

• Add documentation for enums (4f690b9)
• Mark revision_id in CommitSchemaRevisionRequest as deprecated (#861) (09b846d)

Features

• Add schema evolution methods and fields (9479356)
• Add support for python 3.11 (9479356)

Bug Fixes

• deps: Require google-api-core >=1.34.0, >=2.11.0 (060f00b)
• Drop usage of pkg_resources (060f00b)
• Fix timeout default values (060f00b)

Documentation

• samples: Snippetgen should call await on the operation coroutine before calling result (060f00b)

Bug Fixes

• Remove suboptimal logic in leasing behavior (#816) (f067af3)

Bug Fixes

• Batch at most 1,000 ack ids per request (#802) (4361e67)
• deps: Allow protobuf 3.19.5 (#801) (fa23503)
• Silence invalid_ack_id warnings for receipt modacks (#798) (17feea5)

Miscellaneous Chores

• release as 2.13.10 (34f022b)

Bug Fixes

• deps: Require protobuf >= 3.20.2 (#792) (1a54f7c)

Bug Fixes

• Remove expired ack_ids (#787) (b4b809d)

Bug Fixes

• deps: allow protobuf < 5.0.0 (#762) (260bd18)
• deps: require proto-plus >= 1.22.0 (260bd18)
• set stream_ack_deadline to max_duration_per_lease_extension or 60 s, set ack_deadline to min_duration_per_lease_extension or 10 s (#760) (4444129)
• Update stream_ack_deadline with ack_deadline (#763) (e600ad8)

Documentation

• reorganize sphinx structure (#751) (b6de574)

Bug Fixes

• Remove bidi modacks on StreamingPull initial request (#738) (1e7d469)

Bug Fixes

• deps: require google-api-core>=1.32.0,>=2.8.0 (#735) (a5624fb)

Bug Fixes

• deps: require google-api-core >= 2.8.0 (#726) (c80ad41)

Bug Fixes

• change info logs to debug (#693) (950fbce)
• require python 3.7+ (#730) (0d949b8)

2.13.0 (2026-09-14)

Features

• update API sources and regenerate (#18324) (0766fb6)

Bug Fixes

• Add emulator support to schema service (#658) (1a07d7c)
• Handle duplicate acks with streaming pull (#662) (219491e)
• set min snooze on lease management to .01 sec (#678) (91c6e69)

Documentation

• fix project_path typo in UPGRADING.md (#660) (20d661c)
• mark eod as preview (#657) (418e1a3)

Features

• increase GRPC max metadata size to 4 MB (#623) (54b9e07)

Bug Fixes

• mypy errors (#622) (dab13d5)
• process ErrorInfo / GRPC errors for ack/modack only when exactly-once delivery is enabled (#626) (cc1953b)

Features

• retry temporary GRPC statuses for ack/modack/nack when exactly-once delivery is enabled (#607) (a91bed8)
• return singleton success future for exactly-once methods in Message (#608) (253ced2)

Bug Fixes

• deps: require google-api-core>=1.31.5, >=2.3.2 (#600) (1608b7f)
• deps: require proto-plus>=1.15.0 (1608b7f)

Features

• add api key support (#571) (cdda762)
• add exactly once delivery flag (#577) (d6614e2)
• add support for exactly once delivery (#578) (95a86fa)
• exactly-once delivery support (#550) (2fb6e15)

Bug Fixes

• deps: move libcst to extras (#585) (0846762)
• refactor client classes for safer type checking (#552) (7f705be)
• resolve DuplicateCredentialArgs error when using credentials_file (8ca8cf2)

Samples

• samples: create subscription with filtering enabled #580
• samples: handle empty response in sync pull samples #586
• samples: sample for receiving messages with exactly-once delivery enabled #588
• samples: create subscription with exactly once delivery #592 (https://github.com/googleapis/python-pubsub/pull/588

Documentation

• add autogenerated code snippets (aa3754c)
• Docs have inconsistent default values for max_latency and max_bytes (#572) (d136dfd)

Features

• add context manager support in client (#516) (51eae67)
• add support for Python 3.10 (#518) (bb25d75)

Bug Fixes

• add 'dict' annotation type to 'request' (b72522a)
• deps: drop packaging dependency (290b9c5)
• deps: require google-api-core >= 1.28.0 (290b9c5)
• improper types in pagers generation (2ad639d)

Documentation

• add type annotations to codebase (#509) (093cabf)
• list oneofs in docstring (290b9c5)

Features

• closed subscriber as context manager raises (#488) (a05a3f2)

Documentation

• clarify the types of Message parameters (#486) (633e91b)

Bug Fixes

• remove dependency on pytz (#472) (972cc16)

Features

• Add always_use_jwt_access. (1f30ef7)
• Add method signature for Subscriber.Pull without the deprecated return_immediately field. (1f30ef7)
• Add Pub/Sub topic retention fields. (#456) (911829d)
• Add subscription properties to streaming pull response. (1f30ef7)
• Support self-signed JWT flow for service accounts. (1f30ef7)

Bug Fixes

• Add async client to %name_%version/init.py. (1f30ef7)
• Disable always_use_jwt_access. (1f30ef7)
• Enable self signed JWT for gRPC. (#458) (c6e0ff6)

Dependencies

• Add packaging requirement. (1f30ef7)
• Require google-api-core >= 1.26.0. (1f30ef7)

2.6.1 (2026-09-24)

Bug Fixes

• google-cloud-ndb: allow redis 8.x (#18438) (9630fe4)

Features

• support customizable retry and timeout settings on the publisher client (#299) (7597604)

Bug Fixes

• ACK deadline set for received messages can be too low (#416) (e907f6e)
• threads can skip the line in publisher flow controller (#422) (ef89f55)

Documentation

• block until the streaming pull shuts down (#424) (d0d0b70)
• explain that future.cancel() is non-blocking (#420) (c825789)

Features

• Make publish futures compatible with concurrent.futures.as_completed(). (#397) (e29a2c0)

Bug Fixes

• Scheduler errors when executor in shutdown. (#399) (39a83d3)

05-06-2021 23:50 PDT

Implementation Changes

• Fix memory leak when publishing messages. (#406)
• Do not crash if distribution cannot be found when extracting semantic version. (#393)
• Emit a warning if return_immediately is set with synchronous pull. (#355)
• Regenerate GAPIC layer with latest changes, use explicit default timeouts. (#345)

Documentation

• Add additional info on use_legacy_flow_control parameter. (#301)
• Remove EXPERIMENTAL tag for ordering keys in publisher/client.py. (#324)
• Fix create_topic() call in README. (#360)
• Generate PyPI token in secrets manager, fix spacing in docs (via synth). (#384)
• Add SECURITY.md. (#401)

Internal / Testing Changes

• Require 100% unit test coverage (via synth). (#359)
• Bump test coverage to 100%. (#364)
• Fix streaming pull close unit test flakiness. (#361)
• Pass explicit credentials in all unit tests creating clients. (#369)
• Fix flaky test for blocking pull shutdown. (#378)
• Add missing licence header. (#377)

Bug Fixes

• Move await_msg_callbacks flag to subscribe() method, fixing a regression in Pub/Sub Lite client. (#320) (d40d027)
• SSL error when using the client with the emulator. (#297) (83db672)

Implementation Changes

• (samples) Bump the max_time to 10 minutes for a flaky test. (#311) (e2678d4), closes #291
• (samples) Mark delivery attempts test as flaky. (#326) (5a97ef1)
• (samples) Mitigate flakiness in subscriber_tests. (#304) (271a385)
• (samples) Retry InternalServerError in dead letter policy test. (#329) (34c9b11), closes #321

Documentation

• Remove EXPERIMENTAL tag for ordering keys in types.py. (#323) (659cd7a)
• Remove EXPERIMENTAL tag from Schema service (via synth). (#307) (ad85202)

02-22-2021 05:02 PST

Implementation Changes

New Features

• Add graceful streaming pull shutdown. (#292)

Documentation

• Update samples with using the subscriber client as a context manager. (#254)

Features

• surface SchemaServiceClient in google.cloud.pubsub (#281) (8751bcc)

Bug Fixes

• client version missing from the user agent header (#275) (b112f4f)
• Don't open the google.cloud package by adding pubsub.py (#269) (542d79d)
• flaky samples tests (#263) (3d6a29d)
• Modify synth.py to update grpc transport options (#266) (41dcd30)
• pass anonymous credentials for emulator (#250) (8eed8e1)
• remove grpc send/recieve limits (#259) (fd2840c)

Features

• Add dead lettering max delivery attempts argument (#236) (7687ae5)
• Enable server side flow control by default with the option to turn it off (#231) (94d738c)

Bug Fixes

• fix mtls issue in handwritten layer (#226) (09a409c)
• make fixup script consistent with migration docs (#208) (b64e218)

Documentation

• document potentially unexpected blocking behavior of publish() method (#214) (b6d9bd7)
• fix get topic_path in subscriber sample (#210) (7228f6c)

09-21-2020 02:19 PDT

Implementation Changes

• Convert all RPC error types to exceptions. (#163) (#170)
• Pass client options to publisher and subscriber clients. (#166) (#190)

New Features

• Regenerate the client lib to pick new mtls env (via synth). (#197)

Documentation

• Add subscription detachment sample. (#152)
• Use new call syntax in subscriber docs. (#198) (#203)

Internal / Testing Changes

• Update CODEOWNERS. (#193)

09-11-2020 05:03 PDT

Implementation Changes

• Transition the library to microgenerator. (#158) This is a breaking change that introduces several method signature changes and drops support for Python 2.7 and 3.5.

Documentation

• Add samples for using ordering keys. (#156)
• Remove extra white space in delivery attempt sample. (#159)

Internal / Testing Changes

• Fix flaky sequencer unit tests. (#187)

This is the last release that supports Python 2.7 and 3.5.

New Features

• Add support for server-side flow control. (#143) (04e261c)

Dependencies

• Update samples dependency google-cloud-pubsub to v1.6.1. (#144) (1cb6746)

Documentation

• Add pubsub/cloud-client samples from the common samples repo (with commit history). (#151)
• Add flow control section to publish overview. (#129) (acc19eb)
• Add a link to Pub/Sub filtering language public documentation to pubsub.proto. (#121) (8802d81)

Documentation

• added Python2 sunset notice (synth) (#140) (c8f6378)
• explain how to nack a sync pull message (#123) (f2eec65)

Features

• Add flow control for message publishing (#96) (06085c4)

Bug Fixes

• Fix PubSub incompatibility with api-core 1.17.0+ (#103) (c02060f)

Documentation

• Clarify that Schedulers shouldn't be used with multiple SubscriberClients (#100) (cf9e87c)
• Fix update subscription/snapshot/topic samples (#113) (e62c38b)

Internal / Testing Changes

• Re-generated service implementaton using synth: removed experimental notes from the RetryPolicy and filtering features in anticipation of GA, added DetachSubscription (experimental) (#114) (0132a46)
• Incorporate will_accept() checks into publish() (#108) (6c7677e)

Features

• add methods for listing snapshots (via synth) (#66) (4ce898e)
• send client id with StreamingPullRequest (#58) (9f8acfa), closes #62

Bug Fixes

• fix docs warnings in Sphinx 3.0+ (#70) (21e761e)
• restrict api-core dependency to < 1.17.0 (#76) (191b051)

Bug Fixes

• update generated retry timings for publish and pull rpcs via synth (#43) (4f7fe85)
• use client_options.api_endpoint parameter instead of ignoring it (#59) (56b8d7b), closes #61

Bug Fixes

• Don't assert on unordered publishes after publish error. (#49) (ea19ce6)

Features

• pubsub: implement max_duration_per_lease_extension option (#38) (d911a2d)

Bug Fixes

• shutdown error on streaming pull callback error (#40) (552539e)

Features

• pubsub: ordering keys (#26) (cc3093a)
• add context manager capability to subscriber (#32) (b58d0d8)

Features

• pubsub: add delivery attempt property to message object received by user code (#10205) (a0937c1)
• add StreamingPullRequest.client_id field (via synth) (199d56a)

Bug Fixes

• pubsub: handle None in on response callback (#9982) (6596c4b)
• replace unsafe six.PY3 with PY2 for better future compatibility with Python 4 (#10081) (975c1ac)

12-09-2019 18:51 PST

Implementation Changes

• Update client configurations (via synth). (#9784)
• Include request overhead when computing publish batch size overflow. (#9911)
• Split large (mod)ACK requests into smaller ones. (#9594)
• Fix messages delivered multiple times despite a long ACK deadline. (#9525)
• Update batching and flow control parameters to be same as the other client libraries. (#9597)
• Add StreamingPullManager._should_terminate. (#9335)

New Features

• Add stop method. (#9365)

Dependencies

• Add Python 2 sunset banner to documentation. (#9036)

Documentation

• Change spacing in docs templates (via synth). (#9759)

Internal / Testing Changes

• Refactor fake leaser test helper. (#9632)
• Add subscriber role test for streaming. (#9507)

09-30-2019 11:57 PDT

Implementation Changes

• Streaming pull shouldn't need subscriptions.get permission (#9360).

09-27-2019 07:01 PDT

Implementation Changes

• Set default stream ACK deadline to subscriptions'. (#9268)

Documentation

• Fix intersphinx reference to requests. (#9294)
• Link to correct TimeoutError in futures docs. (#9216)

Internal / Testing Changes

• Adjust messaging RPC timeout settings (via synth). #9279

08-29-2019 09:27 PDT

Implementation Changes

• Add 'ReceivedMessage.delivery_attempt' field (via synth). (#9098)
• Remove send/recv msg size limit, update docstrings (via synth). (#8964)

Documentation

• Update docstrings for client kwargs and fix return types uris (#9037)
• Remove CI for gh-pages, use googleapis.dev for api_core refs. (#9085)
• Remove compatability badges from READMEs. (#9035)

Internal / Testing Changes

• Add dead-letter-policy field in preparation for its implementation (via synth) (#9078)

07-31-2019 02:03 PDT

Implementation Changes

• Remove deprecated methods and settings (#8836)

Documentation

• Use double backticks for ReST correctness. (#8829)
• Update intersphinx mapping for requests. (#8805)

07-29-2019 04:28 PDT

Implementation Changes

• PubSub: Deprecate several FlowControl settings and things in Message class (#8796)

Documentation

• Pub/Sub: document regional endpoint (#8789)

07-24-2019 17:13 PDT

Implementation Changes

• Accomodate new location of 'IAMPolicyStub' (via synth). (#8680)
• Use kwargs in test_subscriber_client (#8414)

New Features

• Add options_ argument to clients' get_iam_policy; pin black version (via synth). (#8657)
• Add 'client_options' support, update list method docstrings (via synth). (#8518)

Dependencies

• Bump minimum version for google-api-core to 1.14.0. (#8709)
• Update pin for 'grpc-google-iam-v1' to 0.12.3+. (#8647)

Documentation

• Link to googleapis.dev documentation in READMEs. (#8705)
• Add compatibility check badges to READMEs. (#8288)
• Fix typo in publisher index. (#8619)
• Document how to choose the PubSub auth method (#8429)
• Document different PuSub received message types (#8468)
• PubSub: Document batch settings, make synth operations idempotent (#8448)
• Add custom docstrings for FlowControl enum and values (via synth). (#8426)

Internal / Testing Changes

• Add docs job to publish to googleapis.dev. (#8464)
• Add system tests for PubSub clients (#8277)

06-18-2019 15:14 PDT

Implementation Changes

• Increase the minimum allowed version for api core. (#8419)
• Allow kwargs to be passed to create_channel. (#8399)

06-18-2019 11:32 PDT

Implementation Changes

• Core: Mitigate busy reopen loop in ResumableBidiRpc consuming 100% CPU (#8193)
• Pub/Sub: Increase initial_rpc_timeout for messaging (via synth). (#8219)
• PubSub: Release the state lock before calling the publish api (#8234)
• Pub/Sub: Expose publish retry settings (#8231)
• Prevent unhandled background error on SPM shutdown (#8111)
• Update timeouts, blacken noxfile.py, setup.py (via synth). (#8128)
• PubSub: Fix streaming pull incorrectly handling FlowControl max_messages setting (#7948)

Documentation

• Document PubSub FlowControl settings (#8293)
• Replace readthedocs links with links to github docs. (#8291)
• Pub/Sub: surface publish future in documentation (#8229)
• Pubsub: Separate subscriber and publish future documentation. (#8205)
• Drop mention of long-removed 'policy' object. (#8081)

Internal / Testing Changes

• Pub/Sub: staticmethod check (#8091)
• Add empty lines (via synth). (#8067)

05-15-2019 13:57 PDT

New Features

• Add kms_key_name arg to create_topic; remove BETA warnings (via synth). (#7936)
• Add message ordering (via synth). (#7551)

Implementation Changes

• Propagate subscribe callback errors to main thread (#7954)
• Fix pubsub Streaming Pull shutdown on RetryError (#7863)
• Make PubSub subscriber Scheduler inherit from ABC (#7690)
• Add routing header to method metadata (via synth). (#7623)

Internal / Testing Changes

• Remove classifier for Python 3.4 for end-of-life. (#7535)
• Add nox session docs (via synth). (#7778)
• Pub/Sub (nit): wrong var name in sample (#7705)

03-15-2019 14:09 PDT

Implementation Changes

• Propagate 'RetryError' in 'PublisherClient.publish'. (#7071)
• Protoc-generated serialization update.. (#7091)

New Features

• Add 'authentication_method' to 'PushConfig' (via synth). (#7512)
• Add protos as an artifact to library (#7205)
• Pub/sub: pass transport w/ custom channel to GAPIC API clients. (#7008)

Dependencies

Documentation

• Updated client library documentation URLs. (#7307)
• Update copyright headers
• Fix broken docstring cross-reference links. (#7132)
• Docstring changes from updates to .proto files. (#7054)
• Pick up stub docstring fix in GAPIC generator. (#6978)

Internal / Testing Changes

• Copy proto files alongside protoc versions.

12-17-2018 16:57 PST

Implementation Changes

• Initialize StreamingPullFuture._cancelled as True. (#6901)
• Import iam.policy from google.api_core. (#6741)

Documentation

• Document Python 2 deprecation (#6910)
• Emphasize that returned futures may differ from stdlib futures. (#6875)

Internal / Testing Changes

• Add baseline for synth.metadata
• Update noxfile.
• blacken all gen'd libs (#6792)
• omit local deps (#6701)
• Run black at end of synth.py (#6698)
• Run Black on Generated libraries (#6666)
• Add templates for flake8, coveragerc, noxfile, and black. (#6642)