darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-09-07 15:48:24 -04:00
Code Issues Packages Projects Releases Wiki Activity

track message costs

Browse Source
This commit is contained in:
Kenneth Kehl
2025-02-28 10:08:02 -08:00
parent a04507601b
commit d0fe33cc6e
2 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/celery/scheduled_tasks.py
View File

@@ -266,7 +266,7 @@ def process_delivery_receipts(self):
cloudwatch = AwsCloudwatchClient() cloudwatch = AwsCloudwatchClient()
cloudwatch.init_app(current_app) cloudwatch.init_app(current_app)
start_time = aware_utcnow() - timedelta(minutes=30) start_time = aware_utcnow() - timedelta(minutes=3)
end_time = aware_utcnow() end_time = aware_utcnow()
delivered_receipts, failed_receipts = cloudwatch.check_delivery_receipts( delivered_receipts, failed_receipts = cloudwatch.check_delivery_receipts(
start_time, end_time start_time, end_time

2
app/clients/cloudwatch/aws_cloudwatch.py
View File

@@ -7,7 +7,6 @@ from flask import current_app
from app.clients import AWS_CLIENT_CONFIG, Client from app.clients import AWS_CLIENT_CONFIG, Client
from app.cloudfoundry_config import cloud_config from app.cloudfoundry_config import cloud_config
from app.utils import hilite
class AwsCloudwatchClient(Client): class AwsCloudwatchClient(Client):
@@ -113,7 +112,6 @@ class AwsCloudwatchClient(Client):
message_cost = 0.0 message_cost = 0.0
else: else:
message_cost = float(message_cost) 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") my_timestamp = self._aws_value_or_default(event, "notification", "timestamp")
return { return {