From d0fe33cc6e45620a81cdbe8da3c613610361964d Mon Sep 17 00:00:00 2001 From: Kenneth Kehl <@kkehl@flexion.us> Date: Fri, 28 Feb 2025 10:08:02 -0800 Subject: [PATCH] track message costs --- app/celery/scheduled_tasks.py | 2 +- app/clients/cloudwatch/aws_cloudwatch.py | 2 -- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/app/celery/scheduled_tasks.py b/app/celery/scheduled_tasks.py index 40cdf9382..2ff72780d 100644 --- a/app/celery/scheduled_tasks.py +++ b/app/celery/scheduled_tasks.py @@ -266,7 +266,7 @@ def process_delivery_receipts(self): cloudwatch = AwsCloudwatchClient() cloudwatch.init_app(current_app) - start_time = aware_utcnow() - timedelta(minutes=30) + start_time = aware_utcnow() - timedelta(minutes=3) end_time = aware_utcnow() delivered_receipts, failed_receipts = cloudwatch.check_delivery_receipts( start_time, end_time diff --git a/app/clients/cloudwatch/aws_cloudwatch.py b/app/clients/cloudwatch/aws_cloudwatch.py index 68eaaeb94..0a6d3d7be 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): @@ -113,7 +112,6 @@ class AwsCloudwatchClient(Client): message_cost = 0.0 else: message_cost = float(message_cost) - current_app.logger.info(hilite(f"EVENT {event} message_cost = {message_cost}")) my_timestamp = self._aws_value_or_default(event, "notification", "timestamp") return {