Skip to content

Enable celery task deduplication#558

Merged
lipoja merged 1 commit intorelease-engineering:masterfrom
lipoja:enable_deduplication
Aug 8, 2023
Merged

Enable celery task deduplication#558
lipoja merged 1 commit intorelease-engineering:masterfrom
lipoja:enable_deduplication

Conversation

@lipoja
Copy link
Copy Markdown
Contributor

@lipoja lipoja commented Aug 8, 2023

Before each task execution, instruct the worker to check if this task is a duplicate message.

Deduplication occurs only with tasks that have the same identifier, enabled late acknowledgment, were redelivered by the message broker and their state is SUCCESS in the result backend.

[CLOUDDST-19499]

MichalZelenak
MichalZelenak previously approved these changes Aug 8, 2023
Copy link
Copy Markdown
Collaborator

@yashvardhannanavati yashvardhannanavati left a comment

Choose a reason for hiding this comment

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

Could you please add the missing type?

worker_deduplicate_successful_tasks: bool = True

Before each task execution, instruct the worker to check if this task is a duplicate message.

Deduplication occurs only with tasks that have the same identifier, enabled late acknowledgment, were redelivered by the message broker and their state is SUCCESS in the result backend.

[CLOUDDST-19499]
@lipoja
Copy link
Copy Markdown
Contributor Author

lipoja commented Aug 8, 2023

Could you please add the missing type?

worker_deduplicate_successful_tasks: bool = True

Added, please review again

@lipoja lipoja merged commit 2c3fee0 into release-engineering:master Aug 8, 2023
@lipoja lipoja deleted the enable_deduplication branch April 8, 2025 10:12
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.

3 participants