diff --git a/web/app/tasks/__init__.py b/web/app/tasks/__init__.py index b496975c..154841b7 100644 --- a/web/app/tasks/__init__.py +++ b/web/app/tasks/__init__.py @@ -21,16 +21,11 @@ def check_corpora(): def check_jobs(): - print('check_jobs()') jobs = Job.query.all() - print([job.status for job in jobs]) for job in filter(lambda job: job.status == 'submitted', jobs): - print('pre create_job_service({})'.format(job)) job_utils.create_job_service(job) for job in filter(lambda job: job.status in ['queued', 'running'], jobs): - print('pre checkout_job_service({})'.format(job)) job_utils.checkout_job_service(job) for job in filter(lambda job: job.status == 'canceling', jobs): - print('pre remove_job_service({})'.format(job)) job_utils.remove_job_service(job) db.session.commit() diff --git a/web/app/tasks/job_utils.py b/web/app/tasks/job_utils.py index d5958137..7a4e2109 100644 --- a/web/app/tasks/job_utils.py +++ b/web/app/tasks/job_utils.py @@ -11,7 +11,6 @@ import os def create_job_service(job): - print('create_job_service({})'.format(job)) cmd = '{} -i /files -o /files/output'.format(job.service) if job.service == 'file-setup': cmd += ' -f {}'.format(secure_filename(job.title)) @@ -42,7 +41,6 @@ def create_job_service(job): else: job.status = 'queued' finally: - print('Sending email to {}'.format(job.creator.email)) msg = create_message( job.creator.email, 'Status update for your Job "{}"'.format(job.title), @@ -97,7 +95,6 @@ def checkout_job_service(job): job_result = JobResult(filename=job_result, job=job) db.session.add(job_result) finally: - print('Sending email to {}'.format(job.creator.email)) msg = create_message( job.creator.email, 'Status update for your Job "{}"'.format(job.title),