@@ -805,9 +805,9 @@ async def region_outage_alerts(
805
805
### UNIQUE CACHE KEY ###
806
806
cache_key = provider + region_name
807
807
808
- outage_value : Optional [ProviderRegionOutageModel ] = (
809
- await self . internal_usage_cache . async_get_cache ( key = cache_key )
810
- )
808
+ outage_value : Optional [
809
+ ProviderRegionOutageModel
810
+ ] = await self . internal_usage_cache . async_get_cache ( key = cache_key )
811
811
812
812
if (
813
813
getattr (exception , "status_code" , None ) is None
@@ -1367,12 +1367,11 @@ async def send_alert(
1367
1367
# Get the current timestamp
1368
1368
current_time = datetime .now ().strftime ("%H:%M:%S" )
1369
1369
_proxy_base_url = os .getenv ("PROXY_BASE_URL" , None )
1370
+ alert_type_formatted = f"Alert type: `{ alert_type } `\n "
1370
1371
if alert_type == "daily_reports" or alert_type == "new_model_added" :
1371
- formatted_message = message
1372
+ formatted_message = alert_type_formatted + message
1372
1373
else :
1373
- formatted_message = (
1374
- f"Level: `{ level } `\n Timestamp: `{ current_time } `\n \n Message: { message } "
1375
- )
1374
+ formatted_message = f"{ alert_type_formatted } \n Level: `{ level } `\n Timestamp: `{ current_time } `\n \n Message: { message } "
1376
1375
1377
1376
if kwargs :
1378
1377
for key , value in kwargs .items ():
@@ -1388,9 +1387,9 @@ async def send_alert(
1388
1387
self .alert_to_webhook_url is not None
1389
1388
and alert_type in self .alert_to_webhook_url
1390
1389
):
1391
- slack_webhook_url : Optional [Union [ str , List [ str ]]] = (
1392
- self . alert_to_webhook_url [ alert_type ]
1393
- )
1390
+ slack_webhook_url : Optional [
1391
+ Union [ str , List [ str ] ]
1392
+ ] = self . alert_to_webhook_url [ alert_type ]
1394
1393
elif self .default_webhook_url is not None :
1395
1394
slack_webhook_url = self .default_webhook_url
1396
1395
else :
0 commit comments