dev-python/celery: add 5.3.0_beta1, drop 5.2.6

Closes: https://bugs.gentoo.org/859769
Closes: https://bugs.gentoo.org/841970
Signed-off-by: Anna (cybertailor) Vyalkova <cyber+gentoo@sysrq.in>
This commit is contained in:
Anna (cybertailor) Vyalkova
2022-10-21 20:39:35 +05:00
parent a2621e0bf9
commit ff7f99366c
3 changed files with 61 additions and 49 deletions

View File

@@ -9,31 +9,30 @@ depend() {
use rabbitmq redis logger dns
}
CELERYD_ENABLED=${CELERYD_ENABLED:-"no"}
CELERYD_PID_FILE=${CELERYD_PID_FILE:-"/run/celery/celeryd@%n.pid"}
CELERYD_LOG_FILE=${CELERYD_LOG_FILE:-"/var/log/celery/celeryd@%n.log"}
CELERYD_LOG_LEVEL=${CELERYD_LOG_LEVEL:-"INFO"}
CELERYD_NODES=${CELERYD_NODES:-"celery"}
: ${CELERYD_ENABLED:="no"}
: ${CELERYD_PID_FILE:="/run/celery/celeryd@%n.pid"}
: ${CELERYD_LOG_FILE:="/var/log/celery/celeryd@%n.log"}
: ${CELERYD_LOG_LEVEL:="INFO"}
: ${CELERYD_NODES:="celery"}
CELERYBEAT_ENABLED=${CELERYBEAT_ENABLED:-"no"}
CELERYBEAT_PID_FILE=${CELERYBEAT_PID_FILE:-"/run/celery/celerybeat.pid"}
CELERYBEAT_LOG_FILE=${CELERYBEAT_LOG_FILE:-"/var/log/celery/celerybeat.log"}
CELERYBEAT_LOG_LEVEL=${CELERYBEAT_LOG_LEVEL:-"INFO"}
${CELERYBEAT_ENABLED:="no"}
${CELERYBEAT_PID_FILE:="/run/celery/celerybeat.pid"}
${CELERYBEAT_LOG_FILE:="/var/log/celery/celerybeat.log"}
${CELERYBEAT_LOG_LEVEL:="INFO"}
export CELERY_LOADER
CELERYD_MULTI=${CELERYD_MULTI:-"celery multi"}
CELERYCTL=${CELERYCTL:-"celery"}
CELERYBEAT=${CELERYBEAT:-"celery beat"}
: ${CELERYD_MULTI:="celery multi"}
: ${CELERYCTL:="celery"}
: ${CELERYBEAT:="celery beat"}
CELERYD_OPTS="${CELERYD_OPTS}"
CELERYBEAT_OPTS="${CELERYBEAT_OPTS} -f ${CELERYBEAT_LOG_FILE} -l ${CELERYBEAT_LOG_LEVEL}"
create_dirs() {
local logfile="${1}"
local pidfile="${2}"
local logdir=$(dirname ${logfile})
local piddir=$(dirname ${pidfile})
logfile="${1}"
pidfile="${2}"
logdir=$(dirname ${logfile})
piddir=$(dirname ${pidfile})
checkpath -d -q -m 0750 -o ${CELERY_USER:-"root"}:${CELERY_GROUP:-"root"} ${logdir} ${piddir}
}
@@ -66,9 +65,9 @@ celery_chdir() {
}
wait_pid () {
local pidfile=${1}
local timeout=${STOPTIMEOUT:-"10"}
local PID=$(cat "${pidfile}" 2>/dev/null)
pidfile=${1}
timeout=${STOPTIMEOUT:-"10"}
PID=$(cat "${pidfile}" 2>/dev/null)
while [ -n "${PID}" ] && [ "${timeout}" -ge 1 ]; do
kill -0 ${PID} 2>/dev/null || break
@@ -96,14 +95,14 @@ start_workers() {
stop_workers() {
yesno "${CELERYD_ENABLED}" || return 0
local timeout=${STOPTIMEOUT:-"10"}
timeout=${STOPTIMEOUT:-"10"}
${CELERYD_MULTI} stop ${CELERYD_NODES} --pidfile="${CELERYD_PID_FILE}" || return 1
# Wait for each node
for node in ${CELERYD_NODES}; do
local pidfile=${CELERYD_PID_FILE/\%n/${node}}
local PID=$(cat "${pidfile}" 2>/dev/null)
pidfile=$(echo "${CELERYD_PID_FILE}" | sed "s/%n/${node}/g")
PID=$(cat "${pidfile}" 2>/dev/null)
while [ -n "${PID}" ] && [ "${timeout}" -ge 1 ]; do
kill -0 ${PID} 2>/dev/null || break
timeout=$((${timeout} - 1))
@@ -150,7 +149,7 @@ stop_beat() {
start() {
local cr=0
cr=0
checkconfig || return 1
@@ -166,7 +165,7 @@ start() {
}
stop() {
local cr=0
cr=0
checkconfig || return 1
@@ -182,7 +181,7 @@ stop() {
}
reload() {
local cr=0
cr=0
checkconfig || return 1