aiokafka
aiokafka copied to clipboard
Add Producer waitlist for pending send() items
Changes
Fixes #528
Checklist
- [X] I think the code is well written
- [X] Unit tests for the changes exist
- [X] Documentation reflects the changes
- [X] Add a new news fragment into the
CHANGESfolder- name it
<issue_id>.<type>(e.g.588.bugfix) - if you don't have an
issue_idchange it to the pr id after creating the PR - ensure type is one of the following:
.feature: Signifying a new feature..bugfix: Signifying a bug fix..doc: Signifying a documentation improvement..removal: Signifying a deprecation or removal of public API..misc: A ticket has been closed, but it is not of interest to users.
- Make sure to use full sentences with correct case and punctuation, for example:
Fix issue with non-ascii contents in doctest text files.
- name it
Codecov Report
Merging #814 (0dcb78c) into master (ccbcc25) will increase coverage by
0.06%. The diff coverage is100.00%.
@@ Coverage Diff @@
## master #814 +/- ##
==========================================
+ Coverage 97.49% 97.56% +0.06%
==========================================
Files 30 30
Lines 5434 5452 +18
==========================================
+ Hits 5298 5319 +21
+ Misses 136 133 -3
| Flag | Coverage Δ | |
|---|---|---|
| cext | 88.40% <100.00%> (+0.09%) |
:arrow_up: |
| integration | 97.52% <100.00%> (+0.06%) |
:arrow_up: |
| purepy | 97.10% <100.00%> (+0.06%) |
:arrow_up: |
| unit | 49.74% <88.23%> (+0.25%) |
:arrow_up: |
Flags with carried forward coverage won't be shown. Click here to find out more.
| Impacted Files | Coverage Δ | |
|---|---|---|
| aiokafka/producer/message_accumulator.py | 99.31% <100.00%> (+0.40%) |
:arrow_up: |
| aiokafka/producer/producer.py | 98.53% <100.00%> (ø) |
|
| aiokafka/consumer/fetcher.py | 97.48% <0.00%> (+0.31%) |
:arrow_up: |
Continue to review full report at Codecov.
Legend - Click here to learn more
Δ = absolute <relative> (impact),ø = not affected,? = missing dataPowered by Codecov. Last update ccbcc25...0dcb78c. Read the comment docs.