aio-pika

What's Changed

• Preserve processing errors when the delivery channel closes by @mosquito in #712

Full Changelog: 10.0.2...10.0.3

What's Changed

• fix: declare ready() on AbstractRobustChannel and keep robust types through await and async with by @mosquito in #708
• fix: annotate Exchange.publish() with the values it actually returns by @mosquito in #709
• docs: describe connection and channel callback signatures by @mosquito in #710
• docs: document Channel.default_exchange in the API reference by @mosquito in #711
• fix: make AbstractQueueIterator.aenter an async method by @mosquito in #707

Full Changelog: 10.0.1...10.0.2

What's Changed

• fix: use TypeVar for connect and connect_robust return types by @hasansezertasan in #699

New Contributors

• @hasansezertasan made their first contribution in #699

Full Changelog: 10.0.0...10.0.1

What's Changed

• Add aio-pika-batch to related projects by @g-mill in #700
• Update aiormq to the latest version 7 by @decaz in #702

New Contributors

• @g-mill made their first contribution in #700

Full Changelog: 9.6.2...10.0.0

What's Changed

• Include license file in built distributions via project.license-files by @julia-thorn in #698

New Contributors

• @julia-thorn made their first contribution in #698

Full Changelog: 9.6.1...9.6.2

What's Changed

• Migrate documentation from RST to Markdown (MyST) by @mosquito in #697
• Tests for #669 by @mosquito in #691

Full Changelog: 9.6.0...9.6.1

What's Changed

• Split log.exception calls into an error and a debug by @zware in #693
• chore: Dependency-related updates by @zware in #692
• uv and ruff by @mosquito in #694

Full Changelog: 9.5.8...9.6.0

• Replace WeakSet with set for robust channels tracking #666 by shushpanov

• fix: RobustChannel should not reopen after close() call #658

• python3.8-eol #657
• self-hosted docs

• Fix documentation links

• Fix documentation links

• Fix two bugs by adding more type hints to CallbackCollection. @Darsstar
• Dropped python 3.7 @Darsstar
• QueueIterator raises StopAsyncIteration when channel is closed. @Darsstar

• fix: raise ChannelInvalidStateError at exchange.publish with closed channel #637

What's Changed

• fix: typo from somple to simple by @zhaowen-huang in https://github.com/mosquito/aio-pika/pull/625
• mv Propan mention to FastStream by @Lancetnik in https://github.com/mosquito/aio-pika/pull/581
• 630: Only nack messages upon cancellation of a consumer subscription … by @lfse-slafleur in https://github.com/mosquito/aio-pika/pull/634

New Contributors

• @zhaowen-huang made their first contribution in https://github.com/mosquito/aio-pika/pull/625
• @lfse-slafleur made their first contribution in https://github.com/mosquito/aio-pika/pull/634

Full Changelog: https://github.com/mosquito/aio-pika/compare/9.4.1...9.4.2

What's Changed

• Do not use deprecated datetime.utcnow and datetime.utcfromtimestamp by @decaz in https://github.com/mosquito/aio-pika/pull/610
• add 3.12 by @mosquito in https://github.com/mosquito/aio-pika/pull/603
• Prevent deadlock in RobustChannel.reopen() by @Darsstar in https://github.com/mosquito/aio-pika/pull/622

Full Changelog: https://github.com/mosquito/aio-pika/compare/9.4.0...9.4.1

• drop python 3.7 support
• update aiormq to 6.8.0

• Define empty slots in base classes #598

• new: add custom exchanges to rpc pattern #377 by @cloud-rocket

• Fix restore bug of RobustChannel #578 by @aozupek

• Fix bug with RPC when handling on_close with a RobustConnection #573 by @CodeCorrupt

• Fix reopen of robust channel after close #571 by @decaz. Fixes #570

• URL params passing to aiormq #569
  • Connection.KWARGS_TYPES renamed to Connection.PARAMETERS and rework it to dataclass
  • Connection._parse_kwargs renamed to Connection._parse_parameters
  • AMQP URL parameters documentation article

• Fix race condition in RobustChannel in reopen/ready #566 by @isra17

• use fork friendly random robust queue generation way #560

• Ported publisher confirms tutorial by @MaPePeR #550
• Fixed errored response when aio_pika.patterns.RPC can not serialize the result #552

• Fix badges in docs

• Upgrade requirements in poetry.lock
• Rebuild docs

9.1.0

The bulk of the changes are related to how the library entities are now interconnected. In previous versions of aio_pika.Channel instances not contains a link to the aio_pika.Connection instances for now is contains it.

While I don't want custom code to work directly with the aiormq.Channel instance, this was a public API and I should warn you about the change here. The aio_pika.Channel.channel property is deprecated. Use aio_pika.Channel.get_underlay_chanel() instead.

Now all library entities already use this method.

• Update aiormq version

• Amend Exchange.repr to include class name #527 Also switch to f-strings rather than %-formatting, modelled after Queue.repr.
• Update example code of rpc tutorial #530
• bugfix: kwargs not working in aio_pika.connect_robust #531
• Improve type hints for queue.get() #542

• Prevent 'Task exception was never retrieved' #524 If future.exception() is not called (even on cancelled futures), it seems Python will then log 'Task exception was never retrieved'. Rewriting this logic slightly should hopefully achieve the same functionality while preventing the Python errors.
• Avoid implicitly depending on setuptools #526

• fix README badge
• upgrade requirements

• RPCs: Show exceptions on Host (remote side) #503
• Fixed queue_name was set as channel_name for patterns/master.py #523

• Do not nack if consumer is no_ack in QueueIterator #521

• change classifiers in pyproject.toml

The main goal of this release is the migration to poetry and stronger type checking with mypy.

User code should remain compatible, just test it with mypy. The tests still work the same, without public API changes, this indicates that your code should work without changes, but does not prove it.

Deprecations

• aio_pika.message.HeaderProxy - removed
• aio_pika.message.header_converter - removed
• aio_pika.message.format_headers - removed
• aio_pika.message.Message.headers_raw - prints deprecation warning
• aio_pika.abc.AbstractMessage.headers_raw - removed

• Update aiormq~=6.6.3 #512
• Fix getting futures exceptions #509

• Fix memory leaks around channel close callbacks #496
• Fastest way to reject all messages when queue iterator is closing #498

• Fix memory leak when callback collections is chaining #495

• Prevent "Task exception was never retrieved" on timeout #492

• Fix memory leaks on channel close #491

• allow passing ssl_context to the connection #474. A default parameter has been added to the public API, this does not break anything unless your code relies on the order of the arguments.

• Generated anonymous queue name may conflict #486
• improve typing in multiple library actors #478

• Bump aiormq~=6.4.0 with connection blocking feature
• Connection.update_secret method (#481)

• cannot use client_properties issue #469

• linter fixes in aio_pika.rpc.__all__

Release notes

In this release, there are many changes to the internal API and bug fixes related to sudden disconnection and correct recovery after reconnection.

Unfortunately, the behavior that was in version 7.x was slightly affected. It's the reason the major version has been updated.

The entire set of existing tests passes with minimal changes, therefore, except for some minor changes in behavior, the user code should work either without any modifications or with minimal changes, such as replacing removed deprecated functions with alternatives.

This release has been already tested in a working environment, and now it seems that we have completely resolved all the known issues related to recovery after network failures.

Changes:

• Added tests for unexpected network connection resets and fixed many related problems.
• Added UnderlayChannel and UnderlayConneciton, this is NamedTuples contains all connection and channel related properties. The aiormq.Connection and aiormq.Channel objects are now packaged in this NamedTuples and can be atomically assigned to aio_pika.Connection and aio_pika.Channel objects. The main benefit is the not needed to add locks during the connection, in the best case, the container object is assigned to callee as usual, however, if something goes wrong during the connection, there is no need to clear something in aio_pika.RobustConnection or aio_pika.RobustChannel.
• An __init__ method is now a part of abstract classes for most aio_pika entities.
• Removed explicit relations between aio_pika.Channel and aio_pika.Connection. Now you can't get a aio_pika.Connection instance from the aio_pika.Channel instance.
• Fixed a bug that caused the whole connection was closed when a timeout occurred in one of the channels, in case the channel was waiting for a response frame to an amqp-rpc call.
• Removed deprecated add_close_callback and remove_close_callback methods in aio_pika.Channel. Use aio_pika.Channel.close_callbacks.add(callback, ...) and aio_pika.Channel.close_callbacks.remove(callback, ...) instead.
• Fixed a bug in aio_pika.RobustChannel that caused default_exchane broken after reconnecting.
• The publisher_confirms property of aio_pika.Channel is public now.
• Function get_exchange_name is public now.
• Fixed an error in which the queue iterator could enter a deadlock state, with a sudden disconnection.
• The new entity OneShotCallback helps, for example, to call all the closing callbacks at the channel if the Connection was unexpectedly closed, and the channel closing frame did not come explicitly.

• Make aio_pika.patterns.rpc more extendable.

• Fixes in documentation