<h2 dir="auto">Reproducible example</h2>
<p dir="auto">Install Celery 4.4.7:</p>
<div class="highlight highlight-source-shell notranslate position-relative overflow-auto" dir="auto" data-snippet-clipboard-copy-content="python3 -m pip install -U 'celery[redis]==4.4.7'"><pre class="notranslate">python3 -m pip install -U <span class="pl-s"><span class="pl-pds">'</span>celery[redis]==4.4.7<span class="pl-pds">'</span></span></pre></div>
<p dir="auto">Start Redis on 6395:</p>
<div class="highlight highlight-source-shell notranslate position-relative overflow-auto" dir="auto" data-snippet-clipboard-copy-content="redis-server --daemonize yes --port 6395"><pre class="notranslate">redis-server --daemonize yes --port 6395</pre></div>
<p dir="auto">Create <code class="notranslate">celeryfoo.py</code>:</p>
<div class="highlight highlight-source-python notranslate position-relative overflow-auto" dir="auto" data-snippet-clipboard-copy-content="import time
from celery import Celery

celery = Celery(&quot;hi&quot;)

redis_host = &quot;redis://127.0.0.1:6395/0&quot;
celery.conf.broker_url = redis_host
celery.conf.result_backend = redis_host
celery.conf.beat_schedule = {
    &quot;update-foo&quot;: {
        &quot;task&quot;: 'celeryfoo.update',
        &quot;schedule&quot;: 15,
        &quot;args&quot;: (1, 2, 3)
    },
}
celery.conf.worker_redirect_stdouts = False
celery.conf.worker_log_color = False

@celery.task
def update(a, b, c):
    with open(&quot;foo.log&quot;, &quot;a&quot;) as f:
        f.write(str(time.time()) + &quot;\n&quot;)
    return a, b, c"><pre class="notranslate"><span class="pl-k">import</span> <span class="pl-s1">time</span>
<span class="pl-k">from</span> <span class="pl-s1">celery</span> <span class="pl-k">import</span> <span class="pl-v">Celery</span>

<span class="pl-s1">celery</span> <span class="pl-c1">=</span> <span class="pl-v">Celery</span>(<span class="pl-s">"hi"</span>)

<span class="pl-s1">redis_host</span> <span class="pl-c1">=</span> <span class="pl-s">"redis://127.0.0.1:6395/0"</span>
<span class="pl-s1">celery</span>.<span class="pl-s1">conf</span>.<span class="pl-s1">broker_url</span> <span class="pl-c1">=</span> <span class="pl-s1">redis_host</span>
<span class="pl-s1">celery</span>.<span class="pl-s1">conf</span>.<span class="pl-s1">result_backend</span> <span class="pl-c1">=</span> <span class="pl-s1">redis_host</span>
<span class="pl-s1">celery</span>.<span class="pl-s1">conf</span>.<span class="pl-s1">beat_schedule</span> <span class="pl-c1">=</span> {
    <span class="pl-s">"update-foo"</span>: {
        <span class="pl-s">"task"</span>: <span class="pl-s">'celeryfoo.update'</span>,
        <span class="pl-s">"schedule"</span>: <span class="pl-c1">15</span>,
        <span class="pl-s">"args"</span>: (<span class="pl-c1">1</span>, <span class="pl-c1">2</span>, <span class="pl-c1">3</span>)
    },
}
<span class="pl-s1">celery</span>.<span class="pl-s1">conf</span>.<span class="pl-s1">worker_redirect_stdouts</span> <span class="pl-c1">=</span> <span class="pl-c1">False</span>
<span class="pl-s1">celery</span>.<span class="pl-s1">conf</span>.<span class="pl-s1">worker_log_color</span> <span class="pl-c1">=</span> <span class="pl-c1">False</span>

<span class="pl-en">@<span class="pl-s1">celery</span>.<span class="pl-s1">task</span></span>
<span class="pl-k">def</span> <span class="pl-en">update</span>(<span class="pl-s1">a</span>, <span class="pl-s1">b</span>, <span class="pl-s1">c</span>):
    <span class="pl-k">with</span> <span class="pl-en">open</span>(<span class="pl-s">"foo.log"</span>, <span class="pl-s">"a"</span>) <span class="pl-k">as</span> <span class="pl-s1">f</span>:
        <span class="pl-s1">f</span>.<span class="pl-en">write</span>(<span class="pl-en">str</span>(<span class="pl-s1">time</span>.<span class="pl-en">time</span>()) <span class="pl-c1">+</span> <span class="pl-s">"<span class="pl-cce">\n</span>"</span>)
    <span class="pl-k">return</span> <span class="pl-s1">a</span>, <span class="pl-s1">b</span>, <span class="pl-s1">c</span></pre></div>
<p dir="auto">Start celery worker:</p>
<div class="highlight highlight-source-shell notranslate position-relative overflow-auto" dir="auto" data-snippet-clipboard-copy-content="celery --no-color -A celeryfoo:celery worker --detach -l DEBUG --logfile celery.log"><pre class="notranslate">celery --no-color -A celeryfoo:celery worker --detach -l DEBUG --logfile celery.log</pre></div>
<p dir="auto">Check <code class="notranslate">tail -f celery.log</code>:</p>
<div class="highlight highlight-source-shell notranslate position-relative overflow-auto" dir="auto" data-snippet-clipboard-copy-content="[2020-09-28 11:01:51,908: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 61] Connection refused.
Trying again in 32.00 seconds... (16/100)

[2020-09-28 11:02:24,029: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 61] Connection refused.
Trying again in 32.00 seconds... (16/100)

[2020-09-28 11:02:56,118: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 61] Connection refused.
Trying again in 32.00 seconds... (16/100)

[2020-09-28 11:03:28,221: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 61] Connection refused.
Trying again in 32.00 seconds... (16/100)"><pre class="notranslate">[2020-09-28 11:01:51,908: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:<span class="pl-k">**</span>@127.0.0.1:5672//: [Errno 61] Connection refused.
Trying again <span class="pl-k">in</span> 32.00 seconds... (16/100)

[2020-09-28 11:02:24,029: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:<span class="pl-k">**</span>@127.0.0.1:5672//: [Errno 61] Connection refused.
Trying again <span class="pl-k">in</span> 32.00 seconds... (16/100)

[2020-09-28 11:02:56,118: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:<span class="pl-k">**</span>@127.0.0.1:5672//: [Errno 61] Connection refused.
Trying again <span class="pl-k">in</span> 32.00 seconds... (16/100)

[2020-09-28 11:03:28,221: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:<span class="pl-k">**</span>@127.0.0.1:5672//: [Errno 61] Connection refused.
Trying again <span class="pl-k">in</span> 32.00 seconds... (16/100)</pre></div>
<h2 dir="auto">Mandatory Debugging Information</h2>
<div class="highlight highlight-source-shell notranslate position-relative overflow-auto" dir="auto" data-snippet-clipboard-copy-content="$ sw_vers
ProductName:	Mac OS X
ProductVersion:	10.15.7
BuildVersion:	19H2
$ redis-cli -p 6395 PING
PONG
$ celery --version
4.4.7 (cliffs)
$ python3 --version
Python 3.8.5"><pre class="notranslate">$ sw_vers
ProductName:	Mac OS X
ProductVersion:	10.15.7
BuildVersion:	19H2
$ redis-cli -p 6395 PING
PONG
$ celery --version
4.4.7 (cliffs)
$ python3 --version
Python 3.8.5</pre></div>
<p dir="auto">Hi have an application running with Celery 4.4.2 with the following Daemonizing code:</p>
<p dir="auto">/etc/default/my_celery_service</p>
<div class="snippet-clipboard-content notranslate position-relative overflow-auto" data-snippet-clipboard-copy-content="# Names of nodes to start
#   most people will only start one node:
CELERYD_NODES=&quot;worker1&quot;
#   but you can also start multiple and configure settings
#   for each in CELERYD_OPTS
#CELERYD_NODES=&quot;worker1 worker2 worker3&quot;
#   alternatively, you can specify the number of nodes to start:
#CELERYD_NODES=10

# Absolute or relative path to the 'celery' command:
CELERY_BIN=&quot;/opt/climmob_env/bin/celery&quot;
#CELERY_BIN=&quot;/virtualenvs/def/bin/celery&quot;

# App instance to use
# comment out this line if you don't use an app
#CELERY_APP=&quot;proj&quot;
# or fully qualified:
CELERY_APP=&quot;climmob.config.celery_app&quot;

# Where to chdir at start.
CELERYD_CHDIR=&quot;/opt/climmob/&quot;

# Extra command-line arguments to the worker
CELERYD_OPTS=&quot;--time-limit=300 --concurrency=8&quot;
# Configure node-specific settings by appending node name to arguments:
#CELERYD_OPTS=&quot;--time-limit=300 -c 8 -c:worker2 4 -c:worker3 2 -Ofair:worker1&quot;

# Set logging level to DEBUG
#CELERYD_LOG_LEVEL=&quot;DEBUG&quot;

# %n will be replaced with the first part of the nodename.
CELERYD_LOG_FILE=&quot;/opt/climmob_celery/log/%n%I.log&quot;
CELERYD_PID_FILE=&quot;/opt/climmob_celery/run/%n.pid&quot;

# Workers should run as an unprivileged user.
#   You need to create this user manually (or you can choose
#   a user/group combination that already exists (e.g., nobody).
CELERYD_USER=&quot;root&quot;
CELERYD_GROUP=&quot;root&quot;

# If enabled pid and log directories will be created if missing,
# and owned by the userid/group configured.
CELERY_CREATE_DIRS=1"><pre class="notranslate"><code class="notranslate"># Names of nodes to start
#   most people will only start one node:
CELERYD_NODES="worker1"
#   but you can also start multiple and configure settings
#   for each in CELERYD_OPTS
#CELERYD_NODES="worker1 worker2 worker3"
#   alternatively, you can specify the number of nodes to start:
#CELERYD_NODES=10

# Absolute or relative path to the 'celery' command:
CELERY_BIN="/opt/climmob_env/bin/celery"
#CELERY_BIN="/virtualenvs/def/bin/celery"

# App instance to use
# comment out this line if you don't use an app
#CELERY_APP="proj"
# or fully qualified:
CELERY_APP="climmob.config.celery_app"

# Where to chdir at start.
CELERYD_CHDIR="/opt/climmob/"

# Extra command-line arguments to the worker
CELERYD_OPTS="--time-limit=300 --concurrency=8"
# Configure node-specific settings by appending node name to arguments:
#CELERYD_OPTS="--time-limit=300 -c 8 -c:worker2 4 -c:worker3 2 -Ofair:worker1"

# Set logging level to DEBUG
#CELERYD_LOG_LEVEL="DEBUG"

# %n will be replaced with the first part of the nodename.
CELERYD_LOG_FILE="/opt/climmob_celery/log/%n%I.log"
CELERYD_PID_FILE="/opt/climmob_celery/run/%n.pid"

# Workers should run as an unprivileged user.
#   You need to create this user manually (or you can choose
#   a user/group combination that already exists (e.g., nobody).
CELERYD_USER="root"
CELERYD_GROUP="root"

# If enabled pid and log directories will be created if missing,
# and owned by the userid/group configured.
CELERY_CREATE_DIRS=1
</code></pre></div>
<p dir="auto">/etc/init.d/my_celery_service</p>
<div class="snippet-clipboard-content notranslate position-relative overflow-auto" data-snippet-clipboard-copy-content="#!/bin/sh -e
# ============================================
#  celeryd - Starts the Celery worker daemon.
# ============================================
#
# :Usage: /etc/init.d/celeryd {start|stop|force-reload|restart|try-restart|status}
# :Configuration file: /etc/default/celeryd (or /usr/local/etc/celeryd on BSD)
#
# See http://docs.celeryproject.org/en/latest/userguide/daemonizing.html#generic-init-scripts


### BEGIN INIT INFO
# Provides:          celeryd
# Required-Start:    $network $local_fs $remote_fs
# Required-Stop:     $network $local_fs $remote_fs
# Default-Start:     2 3 4 5
# Default-Stop:      0 1 6
# Short-Description: celery task worker daemon
### END INIT INFO
#
#
# To implement separate init-scripts, copy this script and give it a different
# name.  That is, if your new application named &quot;little-worker&quot; needs an init,
# you should use:
#
#   cp /etc/init.d/celeryd /etc/init.d/little-worker
#
# You can then configure this by manipulating /etc/default/little-worker.
#
VERSION=10.1
echo &quot;celery init v${VERSION}.&quot;
if [ $(id -u) -ne 0 ]; then
    echo &quot;Error: This program can only be used by the root user.&quot;
    echo &quot;       Unprivileged users must use the 'celery multi' utility, &quot;
    echo &quot;       or 'celery worker --detach'.&quot;
    exit 1
fi

origin_is_runlevel_dir () {
    set +e
    dirname $0 | grep -q &quot;/etc/rc.\.d&quot;
    echo $?
}

# Can be a runlevel symlink (e.g., S02celeryd)
if [ $(origin_is_runlevel_dir) -eq 0 ]; then
    SCRIPT_FILE=$(readlink &quot;$0&quot;)
else
    SCRIPT_FILE=&quot;$0&quot;
fi
SCRIPT_NAME=&quot;$(basename &quot;$SCRIPT_FILE&quot;)&quot;

DEFAULT_USER=&quot;celery&quot;
DEFAULT_PID_FILE=&quot;/var/run/celery/%n.pid&quot;
DEFAULT_LOG_FILE=&quot;/var/log/celery/%n%I.log&quot;
DEFAULT_LOG_LEVEL=&quot;INFO&quot;
DEFAULT_NODES=&quot;celery&quot;
DEFAULT_CELERYD=&quot;-m celery worker --detach&quot;

if [ -d &quot;/etc/default&quot; ]; then
	CELERY_CONFIG_DIR=&quot;/etc/default&quot;
else
	CELERY_CONFIG_DIR=&quot;/usr/local/etc&quot;
fi

CELERY_DEFAULTS=${CELERY_DEFAULTS:-&quot;$CELERY_CONFIG_DIR/${SCRIPT_NAME}&quot;}

# Make sure executable configuration script is owned by root
_config_sanity() {
    local path=&quot;$1&quot;
    local owner=$(ls -ld &quot;$path&quot; | awk '{print $3}')
    local iwgrp=$(ls -ld &quot;$path&quot; | cut -b 6)
    local iwoth=$(ls -ld &quot;$path&quot; | cut -b 9)

    if [ &quot;$(id -u $owner)&quot; != &quot;0&quot; ]; then
        echo &quot;Error: Config script '$path' must be owned by root!&quot;
        echo
        echo &quot;Resolution:&quot;
        echo &quot;Review the file carefully, and make sure it hasn't been &quot;
        echo &quot;modified with mailicious intent.  When sure the &quot;
        echo &quot;script is safe to execute with superuser privileges &quot;
        echo &quot;you can change ownership of the script:&quot;
        echo &quot;    $ sudo chown root '$path'&quot;
        exit 1
    fi

    if [ &quot;$iwoth&quot; != &quot;-&quot; ]; then  # S_IWOTH
        echo &quot;Error: Config script '$path' cannot be writable by others!&quot;
        echo
        echo &quot;Resolution:&quot;
        echo &quot;Review the file carefully, and make sure it hasn't been &quot;
        echo &quot;modified with malicious intent.  When sure the &quot;
        echo &quot;script is safe to execute with superuser privileges &quot;
        echo &quot;you can change the scripts permissions:&quot;
        echo &quot;    $ sudo chmod 640 '$path'&quot;
        exit 1
    fi
    if [ &quot;$iwgrp&quot; != &quot;-&quot; ]; then  # S_IWGRP
        echo &quot;Error: Config script '$path' cannot be writable by group!&quot;
        echo
        echo &quot;Resolution:&quot;
        echo &quot;Review the file carefully, and make sure it hasn't been &quot;
        echo &quot;modified with malicious intent.  When sure the &quot;
        echo &quot;script is safe to execute with superuser privileges &quot;
        echo &quot;you can change the scripts permissions:&quot;
        echo &quot;    $ sudo chmod 640 '$path'&quot;
        exit 1
    fi
}

if [ -f &quot;$CELERY_DEFAULTS&quot; ]; then
    _config_sanity &quot;$CELERY_DEFAULTS&quot;
    echo &quot;Using config script: $CELERY_DEFAULTS&quot;
    . &quot;$CELERY_DEFAULTS&quot;
fi

# Sets --app argument for CELERY_BIN
CELERY_APP_ARG=&quot;&quot;
if [ ! -z &quot;$CELERY_APP&quot; ]; then
    CELERY_APP_ARG=&quot;--app=$CELERY_APP&quot;
fi

# Options to su
# can be used to enable login shell (CELERYD_SU_ARGS=&quot;-l&quot;),
# or even to use start-stop-daemon instead of su.
CELERYD_SU=${CELERY_SU:-&quot;su&quot;}
CELERYD_SU_ARGS=${CELERYD_SU_ARGS:-&quot;-s /bin/bash&quot;}

CELERYD_USER=${CELERYD_USER:-$DEFAULT_USER}

# Set CELERY_CREATE_DIRS to always create log/pid dirs.
CELERY_CREATE_DIRS=${CELERY_CREATE_DIRS:-0}
CELERY_CREATE_RUNDIR=$CELERY_CREATE_DIRS
CELERY_CREATE_LOGDIR=$CELERY_CREATE_DIRS
if [ -z &quot;$CELERYD_PID_FILE&quot; ]; then
    CELERYD_PID_FILE=&quot;$DEFAULT_PID_FILE&quot;
    CELERY_CREATE_RUNDIR=1
fi
if [ -z &quot;$CELERYD_LOG_FILE&quot; ]; then
    CELERYD_LOG_FILE=&quot;$DEFAULT_LOG_FILE&quot;
    CELERY_CREATE_LOGDIR=1
fi

CELERYD_LOG_LEVEL=${CELERYD_LOG_LEVEL:-${CELERYD_LOGLEVEL:-$DEFAULT_LOG_LEVEL}}
CELERY_BIN=${CELERY_BIN:-&quot;celery&quot;}
CELERYD_MULTI=${CELERYD_MULTI:-&quot;$CELERY_BIN multi&quot;}
CELERYD_NODES=${CELERYD_NODES:-$DEFAULT_NODES}

export CELERY_LOADER

if [ -n &quot;$2&quot; ]; then
    CELERYD_OPTS=&quot;$CELERYD_OPTS $2&quot;
fi

CELERYD_LOG_DIR=`dirname $CELERYD_LOG_FILE`
CELERYD_PID_DIR=`dirname $CELERYD_PID_FILE`

# Extra start-stop-daemon options, like user/group.
if [ -n &quot;$CELERYD_CHDIR&quot; ]; then
    DAEMON_OPTS=&quot;$DAEMON_OPTS --workdir=$CELERYD_CHDIR&quot;
fi


check_dev_null() {
    if [ ! -c /dev/null ]; then
        echo &quot;/dev/null is not a character device!&quot;
        exit 75  # EX_TEMPFAIL
    fi
}


maybe_die() {
    if [ $? -ne 0 ]; then
        echo &quot;Exiting: $* (errno $?)&quot;
        exit 77  # EX_NOPERM
    fi
}

create_default_dir() {
    if [ ! -d &quot;$1&quot; ]; then
        echo &quot;- Creating default directory: '$1'&quot;
        mkdir -p &quot;$1&quot;
        maybe_die &quot;Couldn't create directory $1&quot;
        echo &quot;- Changing permissions of '$1' to 02755&quot;
        chmod 02755 &quot;$1&quot;
        maybe_die &quot;Couldn't change permissions for $1&quot;
        if [ -n &quot;$CELERYD_USER&quot; ]; then
            echo &quot;- Changing owner of '$1' to '$CELERYD_USER'&quot;
            chown &quot;$CELERYD_USER&quot; &quot;$1&quot;
            maybe_die &quot;Couldn't change owner of $1&quot;
        fi
        if [ -n &quot;$CELERYD_GROUP&quot; ]; then
            echo &quot;- Changing group of '$1' to '$CELERYD_GROUP'&quot;
            chgrp &quot;$CELERYD_GROUP&quot; &quot;$1&quot;
            maybe_die &quot;Couldn't change group of $1&quot;
        fi
    fi
}


check_paths() {
    if [ $CELERY_CREATE_LOGDIR -eq 1 ]; then
        create_default_dir &quot;$CELERYD_LOG_DIR&quot;
    fi
    if [ $CELERY_CREATE_RUNDIR -eq 1 ]; then
        create_default_dir &quot;$CELERYD_PID_DIR&quot;
    fi
}

create_paths() {
    create_default_dir &quot;$CELERYD_LOG_DIR&quot;
    create_default_dir &quot;$CELERYD_PID_DIR&quot;
}

export PATH=&quot;${PATH:+$PATH:}/usr/sbin:/sbin&quot;


_get_pidfiles () {
    # note: multi &lt; 3.1.14 output to stderr, not stdout, hence the redirect.
    ${CELERYD_MULTI} expand &quot;${CELERYD_PID_FILE}&quot; ${CELERYD_NODES} 2&gt;&amp;1
}


_get_pids() {
    found_pids=0
    my_exitcode=0

    for pidfile in $(_get_pidfiles); do
        local pid=`cat &quot;$pidfile&quot;`
        local cleaned_pid=`echo &quot;$pid&quot; | sed -e 's/[^0-9]//g'`
        if [ -z &quot;$pid&quot; ] || [ &quot;$cleaned_pid&quot; != &quot;$pid&quot; ]; then
            echo &quot;bad pid file ($pidfile)&quot;
            one_failed=true
            my_exitcode=1
        else
            found_pids=1
            echo &quot;$pid&quot;
        fi

    if [ $found_pids -eq 0 ]; then
        echo &quot;${SCRIPT_NAME}: All nodes down&quot;
        exit $my_exitcode
    fi
    done
}


_chuid () {
    ${CELERYD_SU} ${CELERYD_SU_ARGS} &quot;$CELERYD_USER&quot; -c &quot;$CELERYD_MULTI $*&quot;
}


start_workers () {
    if [ ! -z &quot;$CELERYD_ULIMIT&quot; ]; then
        ulimit $CELERYD_ULIMIT
    fi
    _chuid $* start $CELERYD_NODES $DAEMON_OPTS     \
                 --pidfile=&quot;$CELERYD_PID_FILE&quot;      \
                 --logfile=&quot;$CELERYD_LOG_FILE&quot;      \
                 --loglevel=&quot;$CELERYD_LOG_LEVEL&quot;    \
                 $CELERY_APP_ARG                    \
                 $CELERYD_OPTS
}


dryrun () {
    (C_FAKEFORK=1 start_workers --verbose)
}


stop_workers () {
    _chuid stopwait $CELERYD_NODES --pidfile=&quot;$CELERYD_PID_FILE&quot;
}


restart_workers () {
    _chuid restart $CELERYD_NODES $DAEMON_OPTS      \
                   --pidfile=&quot;$CELERYD_PID_FILE&quot;    \
                   --logfile=&quot;$CELERYD_LOG_FILE&quot;    \
                   --loglevel=&quot;$CELERYD_LOG_LEVEL&quot;  \
                   $CELERY_APP_ARG                  \
                   $CELERYD_OPTS
}


kill_workers() {
    _chuid kill $CELERYD_NODES --pidfile=&quot;$CELERYD_PID_FILE&quot;
}


restart_workers_graceful () {
    echo &quot;WARNING: Use with caution in production&quot;
    echo &quot;The workers will attempt to restart, but they may not be able to.&quot;
    local worker_pids=
    worker_pids=`_get_pids`
    [ &quot;$one_failed&quot; ] &amp;&amp; exit 1

    for worker_pid in $worker_pids; do
        local failed=
        kill -HUP $worker_pid 2&gt; /dev/null || failed=true
        if [ &quot;$failed&quot; ]; then
            echo &quot;${SCRIPT_NAME} worker (pid $worker_pid) could not be restarted&quot;
            one_failed=true
        else
            echo &quot;${SCRIPT_NAME} worker (pid $worker_pid) received SIGHUP&quot;
        fi
    done

    [ &quot;$one_failed&quot; ] &amp;&amp; exit 1 || exit 0
}


check_status () {
    my_exitcode=0
    found_pids=0

    local one_failed=
    for pidfile in $(_get_pidfiles); do
        if [ ! -r $pidfile ]; then
            echo &quot;${SCRIPT_NAME} down: no pidfiles found&quot;
            one_failed=true
            break
        fi

        local node=`basename &quot;$pidfile&quot; .pid`
        local pid=`cat &quot;$pidfile&quot;`
        local cleaned_pid=`echo &quot;$pid&quot; | sed -e 's/[^0-9]//g'`
        if [ -z &quot;$pid&quot; ] || [ &quot;$cleaned_pid&quot; != &quot;$pid&quot; ]; then
            echo &quot;bad pid file ($pidfile)&quot;
            one_failed=true
        else
            local failed=
            kill -0 $pid 2&gt; /dev/null || failed=true
            if [ &quot;$failed&quot; ]; then
                echo &quot;${SCRIPT_NAME} (node $node) (pid $pid) is down, but pidfile exists!&quot;
                one_failed=true
            else
                echo &quot;${SCRIPT_NAME} (node $node) (pid $pid) is up...&quot;
            fi
        fi
    done

    [ &quot;$one_failed&quot; ] &amp;&amp; exit 1 || exit 0
}


case &quot;$1&quot; in
    start)
        check_dev_null
        check_paths
        start_workers
    ;;

    stop)
        check_dev_null
        check_paths
        stop_workers
    ;;

    reload|force-reload)
        echo &quot;Use restart&quot;
    ;;

    status)
        check_status
    ;;

    restart)
        check_dev_null
        check_paths
        restart_workers
    ;;

    graceful)
        check_dev_null
        restart_workers_graceful
    ;;

    kill)
        check_dev_null
        kill_workers
    ;;

    dryrun)
        check_dev_null
        dryrun
    ;;

    try-restart)
        check_dev_null
        check_paths
        restart_workers
    ;;

    create-paths)
        check_dev_null
        create_paths
    ;;

    check-paths)
        check_dev_null
        check_paths
    ;;

    *)
        echo &quot;Usage: /etc/init.d/${SCRIPT_NAME} {start|stop|restart|graceful|kill|dryrun|create-paths}&quot;
        exit 64  # EX_USAGE
    ;;
esac

exit 0"><pre class="notranslate"><code class="notranslate">#!/bin/sh -e
# ============================================
#  celeryd - Starts the Celery worker daemon.
# ============================================
#
# :Usage: /etc/init.d/celeryd {start|stop|force-reload|restart|try-restart|status}
# :Configuration file: /etc/default/celeryd (or /usr/local/etc/celeryd on BSD)
#
# See http://docs.celeryproject.org/en/latest/userguide/daemonizing.html#generic-init-scripts


### BEGIN INIT INFO
# Provides:          celeryd
# Required-Start:    $network $local_fs $remote_fs
# Required-Stop:     $network $local_fs $remote_fs
# Default-Start:     2 3 4 5
# Default-Stop:      0 1 6
# Short-Description: celery task worker daemon
### END INIT INFO
#
#
# To implement separate init-scripts, copy this script and give it a different
# name.  That is, if your new application named "little-worker" needs an init,
# you should use:
#
#   cp /etc/init.d/celeryd /etc/init.d/little-worker
#
# You can then configure this by manipulating /etc/default/little-worker.
#
VERSION=10.1
echo "celery init v${VERSION}."
if [ $(id -u) -ne 0 ]; then
    echo "Error: This program can only be used by the root user."
    echo "       Unprivileged users must use the 'celery multi' utility, "
    echo "       or 'celery worker --detach'."
    exit 1
fi

origin_is_runlevel_dir () {
    set +e
    dirname $0 | grep -q "/etc/rc.\.d"
    echo $?
}

# Can be a runlevel symlink (e.g., S02celeryd)
if [ $(origin_is_runlevel_dir) -eq 0 ]; then
    SCRIPT_FILE=$(readlink "$0")
else
    SCRIPT_FILE="$0"
fi
SCRIPT_NAME="$(basename "$SCRIPT_FILE")"

DEFAULT_USER="celery"
DEFAULT_PID_FILE="/var/run/celery/%n.pid"
DEFAULT_LOG_FILE="/var/log/celery/%n%I.log"
DEFAULT_LOG_LEVEL="INFO"
DEFAULT_NODES="celery"
DEFAULT_CELERYD="-m celery worker --detach"

if [ -d "/etc/default" ]; then
	CELERY_CONFIG_DIR="/etc/default"
else
	CELERY_CONFIG_DIR="/usr/local/etc"
fi

CELERY_DEFAULTS=${CELERY_DEFAULTS:-"$CELERY_CONFIG_DIR/${SCRIPT_NAME}"}

# Make sure executable configuration script is owned by root
_config_sanity() {
    local path="$1"
    local owner=$(ls -ld "$path" | awk '{print $3}')
    local iwgrp=$(ls -ld "$path" | cut -b 6)
    local iwoth=$(ls -ld "$path" | cut -b 9)

    if [ "$(id -u $owner)" != "0" ]; then
        echo "Error: Config script '$path' must be owned by root!"
        echo
        echo "Resolution:"
        echo "Review the file carefully, and make sure it hasn't been "
        echo "modified with mailicious intent.  When sure the "
        echo "script is safe to execute with superuser privileges "
        echo "you can change ownership of the script:"
        echo "    $ sudo chown root '$path'"
        exit 1
    fi

    if [ "$iwoth" != "-" ]; then  # S_IWOTH
        echo "Error: Config script '$path' cannot be writable by others!"
        echo
        echo "Resolution:"
        echo "Review the file carefully, and make sure it hasn't been "
        echo "modified with malicious intent.  When sure the "
        echo "script is safe to execute with superuser privileges "
        echo "you can change the scripts permissions:"
        echo "    $ sudo chmod 640 '$path'"
        exit 1
    fi
    if [ "$iwgrp" != "-" ]; then  # S_IWGRP
        echo "Error: Config script '$path' cannot be writable by group!"
        echo
        echo "Resolution:"
        echo "Review the file carefully, and make sure it hasn't been "
        echo "modified with malicious intent.  When sure the "
        echo "script is safe to execute with superuser privileges "
        echo "you can change the scripts permissions:"
        echo "    $ sudo chmod 640 '$path'"
        exit 1
    fi
}

if [ -f "$CELERY_DEFAULTS" ]; then
    _config_sanity "$CELERY_DEFAULTS"
    echo "Using config script: $CELERY_DEFAULTS"
    . "$CELERY_DEFAULTS"
fi

# Sets --app argument for CELERY_BIN
CELERY_APP_ARG=""
if [ ! -z "$CELERY_APP" ]; then
    CELERY_APP_ARG="--app=$CELERY_APP"
fi

# Options to su
# can be used to enable login shell (CELERYD_SU_ARGS="-l"),
# or even to use start-stop-daemon instead of su.
CELERYD_SU=${CELERY_SU:-"su"}
CELERYD_SU_ARGS=${CELERYD_SU_ARGS:-"-s /bin/bash"}

CELERYD_USER=${CELERYD_USER:-$DEFAULT_USER}

# Set CELERY_CREATE_DIRS to always create log/pid dirs.
CELERY_CREATE_DIRS=${CELERY_CREATE_DIRS:-0}
CELERY_CREATE_RUNDIR=$CELERY_CREATE_DIRS
CELERY_CREATE_LOGDIR=$CELERY_CREATE_DIRS
if [ -z "$CELERYD_PID_FILE" ]; then
    CELERYD_PID_FILE="$DEFAULT_PID_FILE"
    CELERY_CREATE_RUNDIR=1
fi
if [ -z "$CELERYD_LOG_FILE" ]; then
    CELERYD_LOG_FILE="$DEFAULT_LOG_FILE"
    CELERY_CREATE_LOGDIR=1
fi

CELERYD_LOG_LEVEL=${CELERYD_LOG_LEVEL:-${CELERYD_LOGLEVEL:-$DEFAULT_LOG_LEVEL}}
CELERY_BIN=${CELERY_BIN:-"celery"}
CELERYD_MULTI=${CELERYD_MULTI:-"$CELERY_BIN multi"}
CELERYD_NODES=${CELERYD_NODES:-$DEFAULT_NODES}

export CELERY_LOADER

if [ -n "$2" ]; then
    CELERYD_OPTS="$CELERYD_OPTS $2"
fi

CELERYD_LOG_DIR=`dirname $CELERYD_LOG_FILE`
CELERYD_PID_DIR=`dirname $CELERYD_PID_FILE`

# Extra start-stop-daemon options, like user/group.
if [ -n "$CELERYD_CHDIR" ]; then
    DAEMON_OPTS="$DAEMON_OPTS --workdir=$CELERYD_CHDIR"
fi


check_dev_null() {
    if [ ! -c /dev/null ]; then
        echo "/dev/null is not a character device!"
        exit 75  # EX_TEMPFAIL
    fi
}


maybe_die() {
    if [ $? -ne 0 ]; then
        echo "Exiting: $* (errno $?)"
        exit 77  # EX_NOPERM
    fi
}

create_default_dir() {
    if [ ! -d "$1" ]; then
        echo "- Creating default directory: '$1'"
        mkdir -p "$1"
        maybe_die "Couldn't create directory $1"
        echo "- Changing permissions of '$1' to 02755"
        chmod 02755 "$1"
        maybe_die "Couldn't change permissions for $1"
        if [ -n "$CELERYD_USER" ]; then
            echo "- Changing owner of '$1' to '$CELERYD_USER'"
            chown "$CELERYD_USER" "$1"
            maybe_die "Couldn't change owner of $1"
        fi
        if [ -n "$CELERYD_GROUP" ]; then
            echo "- Changing group of '$1' to '$CELERYD_GROUP'"
            chgrp "$CELERYD_GROUP" "$1"
            maybe_die "Couldn't change group of $1"
        fi
    fi
}


check_paths() {
    if [ $CELERY_CREATE_LOGDIR -eq 1 ]; then
        create_default_dir "$CELERYD_LOG_DIR"
    fi
    if [ $CELERY_CREATE_RUNDIR -eq 1 ]; then
        create_default_dir "$CELERYD_PID_DIR"
    fi
}

create_paths() {
    create_default_dir "$CELERYD_LOG_DIR"
    create_default_dir "$CELERYD_PID_DIR"
}

export PATH="${PATH:+$PATH:}/usr/sbin:/sbin"


_get_pidfiles () {
    # note: multi &lt; 3.1.14 output to stderr, not stdout, hence the redirect.
    ${CELERYD_MULTI} expand "${CELERYD_PID_FILE}" ${CELERYD_NODES} 2&gt;&amp;1
}


_get_pids() {
    found_pids=0
    my_exitcode=0

    for pidfile in $(_get_pidfiles); do
        local pid=`cat "$pidfile"`
        local cleaned_pid=`echo "$pid" | sed -e 's/[^0-9]//g'`
        if [ -z "$pid" ] || [ "$cleaned_pid" != "$pid" ]; then
            echo "bad pid file ($pidfile)"
            one_failed=true
            my_exitcode=1
        else
            found_pids=1
            echo "$pid"
        fi

    if [ $found_pids -eq 0 ]; then
        echo "${SCRIPT_NAME}: All nodes down"
        exit $my_exitcode
    fi
    done
}


_chuid () {
    ${CELERYD_SU} ${CELERYD_SU_ARGS} "$CELERYD_USER" -c "$CELERYD_MULTI $*"
}


start_workers () {
    if [ ! -z "$CELERYD_ULIMIT" ]; then
        ulimit $CELERYD_ULIMIT
    fi
    _chuid $* start $CELERYD_NODES $DAEMON_OPTS     \
                 --pidfile="$CELERYD_PID_FILE"      \
                 --logfile="$CELERYD_LOG_FILE"      \
                 --loglevel="$CELERYD_LOG_LEVEL"    \
                 $CELERY_APP_ARG                    \
                 $CELERYD_OPTS
}


dryrun () {
    (C_FAKEFORK=1 start_workers --verbose)
}


stop_workers () {
    _chuid stopwait $CELERYD_NODES --pidfile="$CELERYD_PID_FILE"
}


restart_workers () {
    _chuid restart $CELERYD_NODES $DAEMON_OPTS      \
                   --pidfile="$CELERYD_PID_FILE"    \
                   --logfile="$CELERYD_LOG_FILE"    \
                   --loglevel="$CELERYD_LOG_LEVEL"  \
                   $CELERY_APP_ARG                  \
                   $CELERYD_OPTS
}


kill_workers() {
    _chuid kill $CELERYD_NODES --pidfile="$CELERYD_PID_FILE"
}


restart_workers_graceful () {
    echo "WARNING: Use with caution in production"
    echo "The workers will attempt to restart, but they may not be able to."
    local worker_pids=
    worker_pids=`_get_pids`
    [ "$one_failed" ] &amp;&amp; exit 1

    for worker_pid in $worker_pids; do
        local failed=
        kill -HUP $worker_pid 2&gt; /dev/null || failed=true
        if [ "$failed" ]; then
            echo "${SCRIPT_NAME} worker (pid $worker_pid) could not be restarted"
            one_failed=true
        else
            echo "${SCRIPT_NAME} worker (pid $worker_pid) received SIGHUP"
        fi
    done

    [ "$one_failed" ] &amp;&amp; exit 1 || exit 0
}


check_status () {
    my_exitcode=0
    found_pids=0

    local one_failed=
    for pidfile in $(_get_pidfiles); do
        if [ ! -r $pidfile ]; then
            echo "${SCRIPT_NAME} down: no pidfiles found"
            one_failed=true
            break
        fi

        local node=`basename "$pidfile" .pid`
        local pid=`cat "$pidfile"`
        local cleaned_pid=`echo "$pid" | sed -e 's/[^0-9]//g'`
        if [ -z "$pid" ] || [ "$cleaned_pid" != "$pid" ]; then
            echo "bad pid file ($pidfile)"
            one_failed=true
        else
            local failed=
            kill -0 $pid 2&gt; /dev/null || failed=true
            if [ "$failed" ]; then
                echo "${SCRIPT_NAME} (node $node) (pid $pid) is down, but pidfile exists!"
                one_failed=true
            else
                echo "${SCRIPT_NAME} (node $node) (pid $pid) is up..."
            fi
        fi
    done

    [ "$one_failed" ] &amp;&amp; exit 1 || exit 0
}


case "$1" in
    start)
        check_dev_null
        check_paths
        start_workers
    ;;

    stop)
        check_dev_null
        check_paths
        stop_workers
    ;;

    reload|force-reload)
        echo "Use restart"
    ;;

    status)
        check_status
    ;;

    restart)
        check_dev_null
        check_paths
        restart_workers
    ;;

    graceful)
        check_dev_null
        restart_workers_graceful
    ;;

    kill)
        check_dev_null
        kill_workers
    ;;

    dryrun)
        check_dev_null
        dryrun
    ;;

    try-restart)
        check_dev_null
        check_paths
        restart_workers
    ;;

    create-paths)
        check_dev_null
        create_paths
    ;;

    check-paths)
        check_dev_null
        check_paths
    ;;

    *)
        echo "Usage: /etc/init.d/${SCRIPT_NAME} {start|stop|restart|graceful|kill|dryrun|create-paths}"
        exit 64  # EX_USAGE
    ;;
esac

exit 0
</code></pre></div>
<p dir="auto">Even my celery_app is the same.<br>
<code class="notranslate">celeryApp = Celery("clmtask", broker="redis://localhost:6379/0", backend="redis://localhost:6379/0")</code></p>
<p dir="auto">But If I move to 4.4.7 the same code does not work with the following message:</p>
<blockquote>
<p dir="auto">[2020-08-17 09:41:22,546: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 111] Connection refused.<br>
Trying again in 2.00 seconds... (1/100)</p>
</blockquote>
<p dir="auto">It seems that 4.4.7 is ignoring my broker and backend parameters or not reading properly CELERY_APP in /etc/default/my_celery_service</p>