openshift-celery-cartridge/bin/control

#!/bin/bash -e

PATH=${OPENSHIFT_CELERY_DIR}bin/:${OPENSHIFT_CELERY_DIR}usr/bin:${OPENSHIFT_CELERY_DIR}conf.d:$OPENSHIFT_DATA_DIR:$OPENSHIFT_DATA_DIR/config/:$PATH

#TODO add scaling, better status, variable worker names, stop workers properly

function start {
    echo  "Starting ${OPENSHIFT_CELERY_DIR}usr/celery multi start worker --config=${OPENSHIFT_CELERY_CONFIG=celeryconfig}  --loglevel=DEBUG --logfile=${OPENSHIFT_TMP_DIR}celery_log.txt"
    ${OPENSHIFT_CELERY_DIR}usr/celery multi start worker --configfile=${OPENSHIFT_CELERY_CONFIG=celeryconfig}  --loglevel=DEBUG --logfile=${OPENSHIFT_TMP_DIR}celery_log.txt
}

function stop {
    if ps -p `cat ${OPENSHIFT_CELERY_DIR}etc/celeryd.pid` > /dev/null; 
    then
        kill -9 `cat ${OPENSHIFT_CELERY_DIR}etc/celeryd.pid`
    else
        echo "nothing to kill"
    fi
    echo "stopped"
}

function restart {
    celery multi restart worker --pidfile=${OPENSHIFT_CELERY_DIR}etc/celeryd.pid
    echo "not yet implemented"
    
}

function status() {
    pid=`cat ${OPENSHIFT_CELERY_DIR}etc/celeryd.pid`
    info=`celery multi show worker`
    client_result $pwd
    if [ -f $pid ] && ( kill -0 $(cat $pid) ); then
        client_result "Celery is running ${info} at pid:${pid}"
    else
        client_result "Celery is not running"
    fi
}

function catchall {
    echo "not yet implemented"
}

case "$1" in
  start)       start ;;
  stop)        stop ;;
  restart)     restart ;;
  status)      status ;;
  reload)      catchall ;;
  tidy)        catchall ;;
  pre-build)   catchall ;;
  build)       catchall ;;
  deploy)      catchall ;;
  post-deploy) catchall ;;
  *)           exit 0
esac

exit 0