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.

Sign up for GitHub

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

Jump to bottom

Solve Kombu filesystem transport not thread safe #1593

Merged
merged 2 commits into from
Sep 7, 2022
Merged

Solve Kombu filesystem transport not thread safe #1593

merged 2 commits into from
Sep 7, 2022

Commits on Sep 6, 2022

  1. Solve Kombu filesystem transport not thread safe 

    fix: celery#398
Currently only write lock used in msg/exchange file written. Cause
reading in other thread got some incomplete result.

1. Add timeout for the lock acquire.
2. Add Share locks when reading message from filesystem.
3. Add a unit test for the `lock` and `unlock`
4. Add a unit test to test the lock during message processing.
    @karajan1001
    karajan1001 committed Sep 6, 2022
    Configuration menu
    Copy the full SHA
    4b7e67d View commit details
    Browse the repository at this point in the history

Commits on Sep 7, 2022

  1. Replace deprecated function.

    @karajan1001
    karajan1001 committed Sep 7, 2022
    Configuration menu
    Copy the full SHA
    8e66845 View commit details
    Browse the repository at this point in the history