diff --git a/app/celery/scheduled_tasks.py b/app/celery/scheduled_tasks.py index d5aaa27a8..94bea4bea 100644 --- a/app/celery/scheduled_tasks.py +++ b/app/celery/scheduled_tasks.py @@ -244,4 +244,7 @@ def process_delivery_receipts(): start_time = utc_now() - timedelta(minutes=10) end_time = utc_now() receipts = cloudwatch.check_delivery_receipts(start_time, end_time) - dao_update_delivery_receipts(receipts) + batch_size = 100 + for i in range(0, len(receipts), batch_size): + batch = receipts[i : i + batch_size] + dao_update_delivery_receipts(batch) diff --git a/app/clients/cloudwatch/aws_cloudwatch.py b/app/clients/cloudwatch/aws_cloudwatch.py index 0d9f58680..cd510e9dd 100644 --- a/app/clients/cloudwatch/aws_cloudwatch.py +++ b/app/clients/cloudwatch/aws_cloudwatch.py @@ -69,10 +69,6 @@ class AwsCloudwatchClient(Client): def check_delivery_receipts(self, start, end): - result = self._client.describe_log_groups() - print(result) - return - region = cloud_config.sns_region account_number = self._extract_account_number(cloud_config.ses_domain_arn)