[backend] Allow settings to be defined for worker subprocesses

beat/web/backend/schedule.py

@@ -405,7 +405,7 @@ def worker_update():
 
 
 @transaction.atomic
-def work(environments, cpulimit, process):
+def work(environments, cpulimit, process, settings):
     '''Launches user code on isolated processes
 
     This function is supposed to be called asynchronously, by a scheduling
@@ -429,6 +429,9 @@ def work(environments, cpulimit, process):
       process (str): The path to the ``process.py`` program to use for running
         the user code on isolated processes.
 
+      settings (str): The name of the module containing the Django settings for
+        use with the process program
+
     '''
 
     # myself, raises if I cannot find me
@@ -441,7 +444,7 @@ def work(environments, cpulimit, process):
         j.end(None, Job.CANCELLED)
 
     # cmdline base argument
-    cmdline = [process]
+    cmdline = [process, '--settings=%s' % settings]
     if cpulimit is not None: cmdline += ['--cpulimit=%s' % cpulimit]
     if settings.DEBUG: cmdline += ['-vv']
 

beat/web/scripts/worker.py

@@ -124,7 +124,7 @@ def main(user_input=None):
         while not stop:
 
             start = time.time()
-            work(environments, cpulimit, process)
+            work(environments, cpulimit, process, arguments['--settings'])
             currtime = time.time()
             duration = currtime - start