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

fix: ensure aiokafka commit is called with kafka.structs.TopicPartiti… #541

Conversation

dada-engineer
Copy link
Collaborator

Make sure AIOKafkaConsumer.commit() receives compatible TopicPartition class. (Fixes #539)

@codecov
Copy link

codecov bot commented Aug 14, 2023

Codecov Report

Patch coverage: 33.33% and project coverage change: -0.03% ⚠️

Comparison is base (87a80a9) 93.73% compared to head (261e61e) 93.70%.

❗ Current head 261e61e differs from pull request most recent head 1c0102b. Consider uploading reports for the commit 1c0102b to get more accurate results

Additional details and impacted files
@@            Coverage Diff             @@
##           master     #541      +/-   ##
==========================================
- Coverage   93.73%   93.70%   -0.03%     
==========================================
  Files         102      102              
  Lines       11149    11154       +5     
  Branches     1532     1534       +2     
==========================================
+ Hits        10450    10452       +2     
- Misses        611      614       +3     
  Partials       88       88              
Files Changed Coverage Δ
faust/transport/drivers/aiokafka.py 73.32% <33.33%> (-0.25%) ⬇️

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

@dada-engineer dada-engineer force-pushed the fix/539-ensure-aiokafka-topic-partitions branch from 261e61e to 3275ea8 Compare August 14, 2023 06:44
@wbarnha
Copy link
Member

wbarnha commented Aug 14, 2023

Thanks for spending the time investigating this, you wouldn't believe how much of a favor this is. Lint the PR and it should be good!

@dada-engineer dada-engineer force-pushed the fix/539-ensure-aiokafka-topic-partitions branch from 3275ea8 to 1c0102b Compare August 14, 2023 14:42
@dada-engineer
Copy link
Collaborator Author

Thanks for spending the time investigating this, you wouldn't believe how much of a favor this is. Lint the PR and it should be good!

Sorry had it done but not commited yet. 👍🏻

Copy link
Member

@wbarnha wbarnha left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Weird, this seems to have fixed the PyPy tests as well? I've never seen them pass before in CI/CD. Thank you, LGTM!

@wbarnha
Copy link
Member

wbarnha commented Aug 14, 2023

Wait, it seems the PyPy test is erroneously marked as passing. I wonder if something in the workflow logic got updated to mark as passing when experimental.

@dada-engineer
Copy link
Collaborator Author

Didn't do anything related to that. Should I?

@wbarnha
Copy link
Member

wbarnha commented Aug 14, 2023

Didn't do anything related to that. Should I?

No need for concern on your end, just got excited too soon about PyPy tests.

@wbarnha wbarnha merged commit b5db8a0 into faust-streaming:master Aug 14, 2023
18 of 19 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Commit structure validation failure: TP != TopicPartition
2 participants