Stop on Exception Parameter

timeloop/app.py

@@ -35,9 +35,10 @@ def _block_main_thread(self):
                 self.stop()
                 break
 
-    def _start_jobs(self, block):
+    def _start_jobs(self, block, stop_on_exception):
         for j in self.jobs:
             j.daemon = not block
+            j.stop_on_exception = stop_on_exception
             j.start()
             self.logger.info("Registered job {}".format(j.execute))
 
@@ -56,9 +57,9 @@ def stop(self):
         self._stop_jobs()
         self.logger.info("Timeloop exited.")
 
-    def start(self, block=False):
+    def start(self, block=False, stop_on_exception=False):
         self.logger.info("Starting Timeloop..")
-        self._start_jobs(block=block)
+        self._start_jobs(block=block,stop_on_exception=stop_on_exception)
 
         self.logger.info("Timeloop now started. Jobs will run based on the interval set")
         if block:

timeloop/job.py

@@ -9,11 +9,16 @@ def __init__(self, interval, execute, *args, **kwargs):
         self.execute = execute
         self.args = args
         self.kwargs = kwargs
+        self.stop_on_exception = False
 
     def stop(self):
         self.stopped.set()
         self.join()
 
     def run(self):
         while not self.stopped.wait(self.interval.total_seconds()):
-            self.execute(*self.args, **self.kwargs)
+            try:
+                self.execute(*self.args, **self.kwargs)
+            except:
+                if self.stop_on_exception:
+                    break