diff --git a/daemon/nopaqued.py b/daemon/nopaqued.py index af70c7201b01619b14c03dec8c95414fcd4234af..2498f75e07f87d1977950598858bd075e45c1a3f 100644 --- a/daemon/nopaqued.py +++ b/daemon/nopaqued.py @@ -6,6 +6,7 @@ from time import sleep # TODO: Check if thread is still alive and execute next thread after that # TODO: Remove unnecessary commits +# TODO: Check line length # check_jobs_thread = None # check_corpora_thread = None # notify_thread = None diff --git a/daemon/tasks/check_jobs.py b/daemon/tasks/check_jobs.py index e699e12e53f2276c3097eb0a033930cbb4adf9be..2b43f0b22f17cfd198b669094a7268ab36a96486 100644 --- a/daemon/tasks/check_jobs.py +++ b/daemon/tasks/check_jobs.py @@ -104,7 +104,6 @@ def __create_job_service(job): def __checkout_job_service(job, scoped_session): logger = init_logger() - scoped_session = Session() service_name = 'job_{}'.format(job.id) try: service = docker_client.services.get(service_name) @@ -136,7 +135,6 @@ def __checkout_job_service(job, scoped_session): job_result = JobResult(dir=results_dir, filename=result, job_id=job.id) scoped_session.add(job_result) - scoped_session.commit() def __remove_job_service(job):