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(marker): differentiate standard and delayed markers #2389

Merged
merged 2 commits into from Feb 10, 2024

Conversation

roggervalf
Copy link
Collaborator

@roggervalf roggervalf commented Jan 20, 2024

a marker from a delayed job could override an existing marker from a standard job as both have the same member value, that cause that a worker picks the marker thinking that all the remaining jobs are in delayed status, so it wait the delay even having standard jobs. In order to avoid that we can just use a different member value for the delayed jobs and bzpopmin will pick the lower value (standard marker "0" with score 0) later it could pick marker "1" with delayed score

@manast
Copy link
Contributor

manast commented Jan 20, 2024

I guess there is more code coming with changes on how to react differently depending on the marker type right?

@roggervalf
Copy link
Collaborator Author

Yeah I think so, I added some todos to double check some commands as well

@roggervalf
Copy link
Collaborator Author

But this pr is only related to this case, it should be ready

@roggervalf roggervalf force-pushed the fix-differentiate-markers branch 2 times, most recently from c3b499a to 9b5964c Compare January 27, 2024 18:52
@roggervalf roggervalf force-pushed the fix-differentiate-markers branch 3 times, most recently from 50e1915 to 0ec77a7 Compare February 3, 2024 03:41
@roggervalf roggervalf merged commit 18ebee8 into master Feb 10, 2024
11 checks passed
@roggervalf roggervalf deleted the fix-differentiate-markers branch February 10, 2024 20:38
github-actions bot pushed a commit that referenced this pull request Feb 10, 2024
## [5.1.10](v5.1.9...v5.1.10) (2024-02-10)

### Performance Improvements

* **marker:** differentiate standard and delayed markers (python) ([#2389](#2389)) ([18ebee8](18ebee8))
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.

None yet

2 participants