Skip to content
Snippets Groups Projects
Commit 452ef959 authored by Anael Beutot's avatar Anael Beutot
Browse files

Implemented stop method of job_manager.

parent 628a5621
No related branches found
No related tags found
No related merge requests found
......@@ -62,7 +62,12 @@ class JobManager(object):
def start(self):
pass
def stop(self):
pass
logger.debug('Stopping all currently running jobs')
for job in self.jobs.itervalues():
try:
job.stop()
except Exception:
pass
class BaseThreadedJob(Thread):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment