fixes #1484, thanks @abastardi

This commit is contained in:
niphlod
2016-10-03 21:09:27 +02:00
parent d602631c7e
commit b7219ba2fd
+2 -1
View File
@@ -477,7 +477,8 @@ def executor(queue, task, out):
# Get controller-specific subdirectory if task.app is of # Get controller-specific subdirectory if task.app is of
# form 'app/controller' # form 'app/controller'
(a, c, f) = parse_path_info(task.app) (a, c, f) = parse_path_info(task.app)
_env = env(a=a, c=c, import_models=True) _env = env(a=a, c=c, import_models=True,
extra_request={'is_scheduler': True})
logging.getLogger().setLevel(level) logging.getLogger().setLevel(level)
f = task.function f = task.function
functions = current._scheduler.tasks functions = current._scheduler.tasks