From 1a203b5c048597c7f97e8c9536804eb6a46ad075 Mon Sep 17 00:00:00 2001 From: Rebecca Law Date: Tue, 1 Oct 2019 13:05:05 +0100 Subject: [PATCH] Add more logging for process_job --- app/celery/tasks.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/app/celery/tasks.py b/app/celery/tasks.py index ded705142..22cf3643d 100644 --- a/app/celery/tasks.py +++ b/app/celery/tasks.py @@ -76,6 +76,7 @@ from app.service.utils import service_allowed_to_send_to def process_job(job_id, sender_id=None): start = datetime.utcnow() job = dao_get_job_by_id(job_id) + current_app.logger.info("Starting process-job task for job id {} with status: {}".format(job_id, job.job_status)) if job.job_status != JOB_STATUS_PENDING: return @@ -101,7 +102,7 @@ def process_job(job_id, sender_id=None): TemplateClass = get_template_class(db_template.template_type) template = TemplateClass(db_template.__dict__) - current_app.logger.debug("Starting job {} processing {} notifications".format(job_id, job.notification_count)) + current_app.logger.info("Starting job {} processing {} notifications".format(job_id, job.notification_count)) for row in RecipientCSV( s3.get_job_from_s3(str(service.id), str(job_id)),