mirror of
https://github.com/getredash/redash.git
synced 2025-12-19 17:37:19 -05:00
Add liveness check for workers (#5886)
* Add liveness check script for workers closes #5885 * delete extra script * Rename worker_healthcheck -> workers_healthcheck --------- Co-authored-by: Arik Fraimovich <arik@arikfr.com>
This commit is contained in:
@@ -22,6 +22,19 @@ worker() {
|
|||||||
exec supervisord -c worker.conf
|
exec supervisord -c worker.conf
|
||||||
}
|
}
|
||||||
|
|
||||||
|
workers_healthcheck() {
|
||||||
|
WORKERS_COUNT=${WORKERS_COUNT}
|
||||||
|
echo "Checking active workers count against $WORKERS_COUNT..."
|
||||||
|
ACTIVE_WORKERS_COUNT=`echo $(rq info --url $REDASH_REDIS_URL -R | grep workers | grep -oP ^[0-9]+)`
|
||||||
|
if [ "$ACTIVE_WORKERS_COUNT" < "$WORKERS_COUNT" ]; then
|
||||||
|
echo "$ACTIVE_WORKERS_COUNT workers are active, Exiting"
|
||||||
|
exit 1
|
||||||
|
else
|
||||||
|
echo "$ACTIVE_WORKERS_COUNT workers are active"
|
||||||
|
exit 0
|
||||||
|
fi
|
||||||
|
}
|
||||||
|
|
||||||
dev_worker() {
|
dev_worker() {
|
||||||
echo "Starting dev RQ worker..."
|
echo "Starting dev RQ worker..."
|
||||||
|
|
||||||
@@ -76,6 +89,10 @@ case "$1" in
|
|||||||
shift
|
shift
|
||||||
worker
|
worker
|
||||||
;;
|
;;
|
||||||
|
workers_healthcheck)
|
||||||
|
shift
|
||||||
|
workers_healthcheck
|
||||||
|
;;
|
||||||
server)
|
server)
|
||||||
shift
|
shift
|
||||||
server
|
server
|
||||||
|
|||||||
Reference in New Issue
Block a user