diff --git a/app/aws/s3.py b/app/aws/s3.py index 20e88ed4d..f2de75d73 100644 --- a/app/aws/s3.py +++ b/app/aws/s3.py @@ -45,7 +45,9 @@ def list_s3_objects(): else: break except Exception as e: - current_app.logger.error(f"An error occurred while regenerating cache {e}") + current_app.logger.error( + f"An error occurred while regenerating cache #notify-admin-1200 {e}" + ) return objects @@ -63,7 +65,9 @@ def get_s3_files(): objects = list_s3_objects() s3res = session.resource("s3", config=AWS_CLIENT_CONFIG) - current_app.logger.info(f"JOBS cache length before regen: {len(JOBS)} #notify-admin-1200") + current_app.logger.info( + f"JOBS cache length before regen: {len(JOBS)} #notify-admin-1200" + ) for object in objects: object_arr = object.split("/") job_id = object_arr[1] @@ -74,7 +78,9 @@ def get_s3_files(): ) if "phone number" in object.lower(): JOBS[job_id] = object - current_app.logger.info(f"JOBS cache length after regen: {len(JOBS)} #notify-admin-1200") + current_app.logger.info( + f"JOBS cache length after regen: {len(JOBS)} #notify-admin-1200" + ) def get_s3_file(bucket_name, file_location, access_key, secret_key, region): diff --git a/app/celery/tasks.py b/app/celery/tasks.py index 5498fda7b..e6ed717e7 100644 --- a/app/celery/tasks.py +++ b/app/celery/tasks.py @@ -443,7 +443,6 @@ def send_inbound_sms_to_service(self, inbound_sms_id, service_id): @notify_celery.task(name="regenerate-job-cache") def regenerate_job_cache(): - print("ENTER REGENERATE_JOB_CACHE") s3.get_s3_files()