Open
Conversation
* Add kerberos support for confluent broker * Update tests
* fix (ag2ai#1668): support all exchange RMQ types in AsyncAPI * chore: bump dependencies
* Remove unused ignores * Add misc ignore comments and remove cast * Revert cast change
* Update mike and dirty-equals versions * Update griffe-typingdoc version * Update mkdocs-material version * Update ruff version and update files * lint: fix ruff * lint: fix mypy --------- Co-authored-by: Nikita Pastukhov <diementros@yandex.ru>
* feat: add broker.request method * feat: kafka request support * feat: confluent request support * merge main * feat: confluent request tests * docs: generate API References * tests: fix broken tests * tests: refactor confluent test client * docs: update rpc examples * chore: deprecate message.decoded_body * refactor: FastAPI 0.5.0 compatibility * docs: remove useless API * refactor: correct Consumer Protocol * fix: correct Confluent FakeConsumer * Ignore override * Proofread docs * Remove unused ignores * Add ignore redundant-cast * fix: correct merge * lint: fix precommit * fix: decoded_body public field compatibility * fix: request respects consume middleware * fix: request respects consume middleware for all brokers * chore: bump version * docs: generate API References * fix: request respects global middlewares scope --------- Co-authored-by: Lancetnik <Lancetnik@users.noreply.github.com> Co-authored-by: Kumaran Rajendhiran <kumaran@airt.ai>
* docs: new way asyncapi * fix: asyncapi tests * test changes * fix: add switch for click deps
* docs/update acknowledgment.md * docs: refactoring after yandex editor * fix(docs): nack_on_error * docs: update manual info * fix(docs): no_action to do_nothing * docs: improve manual info * docs: polish AckPolicy * docs: remove API --------- Co-authored-by: Nikita Pastukhov <diementros@yandex.ru>
…#2279) * refactor: RMQ specification composition instead of inheritance * docs: generate API References * chore: bump python version to 3.10 * refactor: NATS specification composition instead of inheritance * chore: use pep 735 for dependencies * refactor: Kafka Specification composition * refactor: Confluent Specification composition * refactor: Redis Specification composition * chore: uv install with groups * chore: uv use public extras * chore: uv use public extras * test: mark slow tests flaky
borisalekseev
force-pushed
the
feat/multiprocessing-worker-id-option
branch
from
a71d4cc to
38f2ac1
Compare
* chore: correct cursor rule metainfo * tests: do not check status code * tests: adopt select to windows * tests: graceful CLI stopping * tests: suppress joined error * docs: generate API References * tests: revert conftest changes * docs: generate API References * tests: graceful application stop * docs: generate API References * tests: improve stderr wait * tests: improve stderr wait * tests: kill windows * docs: generate API References * tests: correct windows signal
* feat: FS-2031 added docker compose and justfile * feat: FS-2031 added justfile and docker compose for developers * feat: FS-2031 fix ci * feat: FS-2031 fix ci just * feat: FS-2031 fix ci build docs * change to 0.6 * remove lcal pre commit, return scripts * docs: generate API References --------- Co-authored-by: Pastukhov Nikita <nikita@pastukhov-dev.ru>
* Feat: add test to msgspec * Fix: tests * chore: little msgspec tests polish * Add serializer for RMQ * Add no all broker * Fix: remove marker * Fix: add import * docs: generate API References * chore: update FastDepends * tests: mark multiprocess test flaky * tests: add tests for all brokers * Fix: drop serializer re-encoding, use json_dumps * chore: update cursor rules * chore: mark asgi-workers CLI test flaky --------- Co-authored-by: Nikita Pastukhov <diementros@yandex.ru> Co-authored-by: Pastukhov Nikita <nikita@pastukhov-dev.ru>
borisalekseev
force-pushed
the
feat/multiprocessing-worker-id-option
branch
from
38f2ac1 to
8f5b91c
Compare
borisalekseev
force-pushed
the
feat/multiprocessing-worker-id-option
branch
from
8f5b91c to
902b812
Compare
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
16 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
No description provided.