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 273 commits into
base: main
Choose a base branch
from
Draft

0.6.0 #1779

wants to merge 273 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, fixes #1954, close #1646

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 December 7, 2024 18:56
* feat: init_routes added routes to init broker

* docs: generate API References

---------

Co-authored-by: Rusich90 <Rusich90@users.noreply.github.com>
* Fix: return logger, typing

* Fix: lint

* chore: fix tests

---------

Co-authored-by: Daniil Dumchenko <dumchenko.de@sibvaleo.com>
Co-authored-by: Nikita Pastukhov <diementros@yandex.ru>
* Feat: replace subscribers

* Fix: lint

* Fix: add mixin

* Fix: lint

* Fix: add markers

* chore: fix tests

---------

Co-authored-by: Daniil Dumchenko <dumchenko.de@sibvaleo.com>
Co-authored-by: Pastukhov Nikita <nikita@pastukhov-dev.ru>
Co-authored-by: Nikita Pastukhov <diementros@yandex.ru>
* feat: add application state

* docs: generate API References

---------

Co-authored-by: Artem-Safronov <Artem-Safronov@users.noreply.github.com>
…and convert Doc to doc string. (#1983)

* feat: change returns kafka publish, change annotation and convert Doc to doc string

* docs: generate API References

* delete docs

* change annotations on broker publish and publish_batch

* add tests and use lint.sh

---------

Co-authored-by: spataphore1337 <spataphore1337@users.noreply.github.com>
* feat: add raise BatchBufferOverflowException

* Update producer.py

---------

Co-authored-by: Pastukhov Nikita <nikita@pastukhov-dev.ru>
* feat: delayed broker setting

* feat: tests for delayed broker setting

* feat: addition test

* feat: broker -> **brokers

* feat: ruff
* feat: moved the creation of metrics to functions

* feat: ruff

* feat: pretty prometheus tests

* feat: ruff

* feat: fix test
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