Fix issue saltstack#8941

olliewalsh · Dec 2, 2013 · 8287633 · 8287633
1 parent 49e3964
commit 8287633
Showing 1 changed file with 11 additions and 9 deletions.
diff --git a/salt/utils/schedule.py b/salt/utils/schedule.py
@@ -243,15 +243,17 @@ def eval(self):
                               'job {0}, defaulting to 1.'.format(job))
                     data['maxrunning'] = 1
 
-            if self.opts.get('multiprocessing', True):
-                thread_cls = multiprocessing.Process
-            else:
-                thread_cls = threading.Thread
-            proc = thread_cls(target=self.handle_func, args=(func, data))
-            proc.start()
-            if self.opts.get('multiprocessing', True):
-                proc.join()
-            self.intervals[job] = int(time.time())
+            try:
+                if self.opts.get('multiprocessing', True):
+                    thread_cls = multiprocessing.Process
+                else:
+                    thread_cls = threading.Thread
+                proc = thread_cls(target=self.handle_func, args=(func, data))
+                proc.start()
+                if self.opts.get('multiprocessing', True):
+                    proc.join()
+            finally:
+                self.intervals[job] = int(time.time())
 
 
 def clean_proc_dir(opts):