summaryrefslogtreecommitdiff
path: root/apscheduler
diff options
context:
space:
mode:
Diffstat (limited to 'apscheduler')
-rw-r--r--apscheduler/schedulers/background.py4
-rw-r--r--apscheduler/schedulers/blocking.py4
2 files changed, 6 insertions, 2 deletions
diff --git a/apscheduler/schedulers/background.py b/apscheduler/schedulers/background.py
index 03f2982..bb8f77d 100644
--- a/apscheduler/schedulers/background.py
+++ b/apscheduler/schedulers/background.py
@@ -29,7 +29,9 @@ class BackgroundScheduler(BlockingScheduler):
super(BackgroundScheduler, self)._configure(config)
def start(self, *args, **kwargs):
- self._event = Event()
+ if self._event is None or self._event.is_set():
+ self._event = Event()
+
BaseScheduler.start(self, *args, **kwargs)
self._thread = Thread(target=self._main_loop, name='APScheduler')
self._thread.daemon = self._daemon
diff --git a/apscheduler/schedulers/blocking.py b/apscheduler/schedulers/blocking.py
index e617157..4ecc9f6 100644
--- a/apscheduler/schedulers/blocking.py
+++ b/apscheduler/schedulers/blocking.py
@@ -14,7 +14,9 @@ class BlockingScheduler(BaseScheduler):
_event = None
def start(self, *args, **kwargs):
- self._event = Event()
+ if self._event is None or self._event.is_set():
+ self._event = Event()
+
super(BlockingScheduler, self).start(*args, **kwargs)
self._main_loop()