Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

0.6.0 #1779

Draft
wants to merge 232 commits into
base: main
Choose a base branch
from
Draft

0.6.0 #1779

wants to merge 232 commits into from

Conversation

Lancetnik
Copy link
Member

@Lancetnik Lancetnik commented Sep 10, 2024

Description

Please include a summary of the change and specify which issue is being addressed. Additionally, provide relevant motivation and context.

fixes #1742, close #1308, close #1228, close #980, fixes #1742, #1895 feature

Breaking changes:

  1. Drop Python3.8 support
  2. @broker.subscriber(..., filters=...) removed
  3. message.decoded_body removed, use await message.decode() instead
  4. publish(..., rpc=True) removed, use broker.request() instead
  5. RabbitMQ @broker.subscriber(..., reply_config=...) removed, use Response instead
  6. Context("broker") and Context("logger") moved to local context. They can not be accessed in lifespan hooks anymore
  7. FastStream(broker) is positional-only argument now (preparing to FastStream(*brokers) support)
  8. FastStream(**asyncapi_options) doesn't work anymore. Now, you have to create special AsyncAPI(broker, **asyncapi_options) to render documentation
  9. FastStream(broker) is POSITIONAL-ONLY option now. FastStream(broker=broker) doesn't work anymore
  10. broker.subscriber(..., retry=True) removed, use ack_policy instead

Lancetnik and others added 30 commits November 6, 2024 20:45
* refactor: add ack handling for brokers

* fix: warnings arguments and is_manual flag

* refactor: complete NATS

* docs: generate API References

* fix: update ack_policy

* refactor: new tests

* refactor: move ack_policy reject outside of return functions

* tests: fix NATS tests

* refactor: validate warnings

* chore: remove loguru usage

* chore: remove deprecated type option

* chore: correct warnings stacklevel

---------

Co-authored-by: vectorvp <[email protected]>
Co-authored-by: Pastukhov Nikita <[email protected]>
* refactor: new Specification Schema

* fix: add missing pre-commit changes

* refactor: delete defaults

* refactor: polish AsyncAPI all brokers

* fix: add missing pre-commit changes

---------

Co-authored-by: Lancetnik <[email protected]>
)

* Remove `retry` from block and add acknowledgement to getting start

* fix pre-commit
* feat: added ack_first

* docs: generate API References

* feat: ack_first added deprecated and docstrings to Ack_Policy

* docs: generate API References

* feat: ack_first refactored ack_first check

* chore: merge 0.6

* docs: generate API References

---------

Co-authored-by: Rusich90 <[email protected]>
Co-authored-by: Nikita Pastukhov <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Core Issues related to core FastStream functionality and affects to all brokers enhancement New feature or request
Projects
Status: In Progress
8 participants