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

SQS: Fix message arg in backoff policy #1496

Merged
merged 1 commit into from
Mar 4, 2022

Conversation

matmarczak
Copy link

@matmarczak matmarczak commented Feb 25, 2022

Hi!

I just found an error in SQS implementation regarding backoff tasks. There was already notion of this here or here. I still experience this problem when backoff policy is defined explicitly. Prepared small example to reproduce issue. Fix is in this PR.

I'm open to comments and happy to improve this PR!
Error is here:
err.txt

Copy link
Member

@auvipy auvipy left a comment

Choose a reason for hiding this comment

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

can you fix the lint error please?

kombu/transport/SQS.py Outdated Show resolved Hide resolved
@matmarczak matmarczak force-pushed the fix-message-arg-in-sqs branch 2 times, most recently from aff069e to 9400f49 Compare March 1, 2022 17:08
Copy link
Member

@thedrow thedrow left a comment

Choose a reason for hiding this comment

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

This is much better. Thanks!

@thedrow thedrow requested a review from auvipy March 3, 2022 12:10
@auvipy auvipy merged commit 907c046 into celery:master Mar 4, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants