|
@@ -27,6 +27,8 @@ __all__ = ['detached_celeryd', 'detach']
|
|
|
|
|
|
logger = get_logger(__name__)
|
|
|
|
|
|
+C_FAKEFORK = os.environ.get('C_FAKEFORK')
|
|
|
+
|
|
|
OPTION_LIST = daemon_options(default_pidfile='celeryd.pid') + (
|
|
|
Option('--fake',
|
|
|
default=False, action='store_true', dest='fake',
|
|
@@ -36,6 +38,7 @@ OPTION_LIST = daemon_options(default_pidfile='celeryd.pid') + (
|
|
|
|
|
|
def detach(path, argv, logfile=None, pidfile=None, uid=None,
|
|
|
gid=None, umask=0, working_directory=None, fake=False, app=None):
|
|
|
+ fake = 1 if C_FAKEFORK else fake
|
|
|
with detached(logfile, pidfile, uid, gid, umask, working_directory, fake):
|
|
|
try:
|
|
|
os.execv(path, [path] + argv)
|