@@ -54,23 +54,23 @@ def dump_logs_from_cloudwatch(e, region="us-west-2"):
5454 endpoint = endpoint_match .group (1 )
5555 log_group_name = f"/aws/sagemaker/Endpoints/{ endpoint } "
5656 try :
57- log_stream_resp = logs_client .describe_log_streams (logGroupName = log_group_name )
58- all_traffic_log_stream = ""
59- for log_stream in log_stream_resp .get ("logStreams" , []):
60- log_stream_name = log_stream .get ("logStreamName" )
61- if log_stream_name .startswith ("AllTraffic" ):
62- all_traffic_log_stream = log_stream_name
63- break
64- if not all_traffic_log_stream :
65- raise NoLogStreamFoundError (
66- f"Cannot find all traffic log streams for endpoint { endpoint } "
57+ log_stream_resp = logs_client .describe_log_streams (logGroupName = log_group_name )
58+ all_traffic_log_stream = ""
59+ for log_stream in log_stream_resp .get ("logStreams" , []):
60+ log_stream_name = log_stream .get ("logStreamName" )
61+ if log_stream_name .startswith ("AllTraffic" ):
62+ all_traffic_log_stream = log_stream_name
63+ break
64+ if not all_traffic_log_stream :
65+ raise NoLogStreamFoundError (
66+ f"Cannot find all traffic log streams for endpoint { endpoint } "
67+ ) from e
68+ events = logs_client .get_log_events (
69+ logGroupName = log_group_name , logStreamName = all_traffic_log_stream
70+ )
71+ raise SageMakerEndpointFailure (
72+ f"Error from endpoint { endpoint } :\n { json .dumps (events , indent = 4 )} "
6773 ) from e
68- events = logs_client .get_log_events (
69- logGroupName = log_group_name , logStreamName = all_traffic_log_stream
70- )
71- raise SageMakerEndpointFailure (
72- f"Error from endpoint { endpoint } :\n { json .dumps (events , indent = 4 )} "
73- ) from e
7474 except logs_client .exceptions .ResourceNotFoundException :
7575 # Log group doesn't exist yet - endpoint may have failed before creating logs
7676 raise SageMakerEndpointFailure (
0 commit comments