diff --git a/beat/web/backend/local_scheduler.py b/beat/web/backend/local_scheduler.py index bc270cb0bea67dcd9d331aad71acd35df10636e9..fc799842f1db43c94cc65b1a2a5b5004954c748f 100755 --- a/beat/web/backend/local_scheduler.py +++ b/beat/web/backend/local_scheduler.py @@ -27,6 +27,7 @@ from django.conf import settings +from django import db import multiprocessing import psutil @@ -94,6 +95,8 @@ def start_scheduler(settings_module='beat.web.settings.settings', interval=5, if getattr(settings, 'LOCAL_SCHEDULER_VERBOSITY', None) is not None: args.append(settings.LOCAL_SCHEDULER_VERBOSITY) + db.connections.close_all() + process = SchedulerProcess(args) process.start() process.queue.get()