loggers

app_context_rqworker.py

@@ -58,8 +58,12 @@ def get_worker(queues):
 
 
 @retry(3)
-def run_worker(queues):
+def run_worker(queues, logger):
     with get_worker(queues) as w:
+        try:
+            w.log = logger
+        except Exception:
+            logger.warning('Unable to set logger')
         w.work()
 
 
@@ -69,4 +73,4 @@ def run_worker(queues):
     with Connection(sentinel.master):
         qs = map(Queue, sys.argv[1:]) or [Queue()]
 
-        run_worker(qs)
+        run_worker(qs, app.logger)

run_scheduler.py

@@ -1,15 +1,16 @@
+import logging
 import os
 from redis import StrictRedis
 from redis.sentinel import Sentinel
 from rq_scheduler.scheduler import Scheduler
-from rq.logutils import setup_loghandlers
-from flask import Flask
 from time import sleep
 import app_settings
 
 
+logging.basicConfig(format='%(asctime)s %(message)s', level=logging.DEBUG)
+
+
 def run_scheduler():
-    setup_loghandlers('DEBUG')
     conn_kwargs = {
         'db': app_settings.config.get('REDIS_DB') or 0,
         'password': app_settings.config.get('REDIS_PWD')