@@ -757,7 +757,6 @@ def _create_deployment(
757
757
logger .info (
758
758
f"Aqua model deployment { deployment_id } created for model { aqua_model_id } . Work request Id is { deployment .dsc_model_deployment .workflow_req_id } "
759
759
)
760
- status_list = []
761
760
762
761
progress_thread = threading .Thread (
763
762
target = self .get_deployment_status ,
@@ -1301,45 +1300,24 @@ def get_deployment_status(
1301
1300
poll_interval = DEFAULT_POLL_INTERVAL ,
1302
1301
)
1303
1302
except Exception :
1304
- status = ""
1305
- logs = deployment .show_logs ().sort_values (by = "time" , ascending = False )
1306
-
1307
- if logs and len (logs ) > 0 :
1308
- status = logs .iloc [0 ]["message" ]
1309
-
1310
- status = re .sub (r"[^a-zA-Z0-9]" , " " , status )
1311
-
1312
1303
if data_science_work_request ._error_message :
1313
1304
error_str = ""
1314
1305
for error in data_science_work_request ._error_message :
1315
1306
error_str = error_str + " " + error .message
1316
1307
1317
1308
error_str = re .sub (r"[^a-zA-Z0-9]" , " " , error_str )
1318
- telemetry_kwargs = {
1319
- "ocid" : ocid ,
1320
- "model_name" : model_name ,
1321
- "work_request_error" : error_str ,
1322
- "status" : status ,
1323
- }
1324
1309
1325
- self .telemetry .record_event (
1326
- category = f"aqua/{ model_type } /deployment/status" ,
1327
- action = "FAILED" ,
1328
- ** telemetry_kwargs ,
1329
- )
1330
- else :
1331
1310
telemetry_kwargs = {
1332
1311
"ocid" : ocid ,
1333
1312
"model_name" : model_name ,
1334
- "status " : status ,
1313
+ "work_request_error " : error_str ,
1335
1314
}
1336
1315
1337
1316
self .telemetry .record_event (
1338
1317
category = f"aqua/{ model_type } /deployment/status" ,
1339
1318
action = "FAILED" ,
1340
1319
** telemetry_kwargs ,
1341
1320
)
1342
-
1343
1321
else :
1344
1322
telemetry_kwargs = {"ocid" : ocid , "model_name" : model_name }
1345
1323
self .telemetry .record_event (
0 commit comments