vault / celery
зеркало
https://github.com/celery/celery.git PULL
CI/CD
Реестр контейнеров и пакетов
    sandeep kesarwani
    Add worker_eta_task_limit configuration to manage ETA task memory usage (#9853) * Add worker_eta_task_limit configuration to manage ETA task memory usage - Introduced `worker_eta_task_limit` to limit the number of ETA/countdown tasks a worker can hold in memory, preventing memory exhaustion. - Updated the task execution strategy to reject new ETA tasks when the limit is reached. - Added documentation for the new configuration option. - Implemented unit tests to validate the behavior of the ETA task limit. * Update docs/userguide/configuration.rst * Implement ETA task limit checks and callbacks in task execution strategy * Add ETA task limit configuration and enforcement in worker strategy - Introduced `worker_eta_task_limit` setting to limit the number of ETA tasks a worker can hold in memory. - Implemented `ETATaskTracker` class to track and enforce the ETA task limit. - Updated `default` strategy to reject new ETA tasks when the limit is reached. - Added unit tests to verify the behavior of the ETA task limit and tracker. * Fix retrieval of worker ETA task limit configuration to handle missing attribute gracefully * Refactor ETA task limit handling in default strategy and update tests for QoS limits * Remove ETA task limit handling from default strategy implementation * Rename eta_task_limit to worker_eta_task_limit and update QoS handling in task consumer * Rename worker_eta_task_limit to eta_task_limit for consistency in configuration * fix: access worker_eta_task_limit as field * docs: update ETA task limit description for clarity --------- Co-authored-by: Asif Saif Uddin {"Auvi":"অভি"} <auvipy@gmail.com>
    1 день назад История
    Описание

    Distributed Task Queue (development branch)

    docs.celeryproject.org/en/stable/index.html
    Python
    0 Форки
    0 Звезд
    0 Наблюдатели
    Конвейеры
    0 успешных
    0 с ошибкой