diff --git a/app/celery/scheduled_tasks.py b/app/celery/scheduled_tasks.py index 25e4d5034..2c31c3f4e 100644 --- a/app/celery/scheduled_tasks.py +++ b/app/celery/scheduled_tasks.py @@ -252,7 +252,7 @@ def process_delivery_receipts(self): it does fail, we need to go back over at some point when things are running again and process those results. """ try: - batch_size = 200 # in theory with postgresql this could be 10k to 20k? + batch_size = 1000 # in theory with postgresql this could be 10k to 20k? cloudwatch = AwsCloudwatchClient() cloudwatch.init_app(current_app) diff --git a/app/clients/cloudwatch/aws_cloudwatch.py b/app/clients/cloudwatch/aws_cloudwatch.py index 5c34cce4d..c83fd6313 100644 --- a/app/clients/cloudwatch/aws_cloudwatch.py +++ b/app/clients/cloudwatch/aws_cloudwatch.py @@ -7,7 +7,6 @@ from flask import current_app from app.clients import AWS_CLIENT_CONFIG, Client from app.cloudfoundry_config import cloud_config -from app.utils import hilite class AwsCloudwatchClient(Client): @@ -49,7 +48,6 @@ class AwsCloudwatchClient(Client): def _get_log(self, log_group_name, start, end): # Check all cloudwatch logs from the time the notification was sent (currently 5 minutes previously) until now - print(hilite(f"START {start} END {end}")) next_token = None all_log_events = []