@@ -1107,50 +1107,7 @@ def format_pregel_job_data(body: Json) -> Json:
11071107
11081108 # The detail element was introduced in 3.10
11091109 if "detail" in body :
1110- d : Json = {}
1111- detail = body ["detail" ]
1112- if "workerStatus" in detail :
1113- d ["workerStatus" ] = detail ["workerStatus" ]
1114- if "aggregatedStatus" in detail :
1115- aggregatedStatus = detail ["aggregatedStatus" ]
1116- aStat : Json = {}
1117- if "timeStamp" in aggregatedStatus :
1118- aStat ["timeStamp" ] = aggregatedStatus ["timeStamp" ]
1119- if "graphStoreStatus" in aggregatedStatus :
1120- graphStoreStatus = aggregatedStatus ["graphStoreStatus" ]
1121- gsStat : Json = {}
1122- if "verticesLoaded" in graphStoreStatus :
1123- gsStat ["verticesLoaded" ] = graphStoreStatus ["verticesLoaded" ]
1124- if "edgesLoaded" in graphStoreStatus :
1125- gsStat ["edgesLoaded" ] = graphStoreStatus ["edgesLoaded" ]
1126- if "memoryBytesUsed" in graphStoreStatus :
1127- gsStat ["memoryBytesUsed" ] = graphStoreStatus ["memoryBytesUsed" ]
1128- if "verticesStored" in graphStoreStatus :
1129- gsStat ["verticesStored" ] = graphStoreStatus ["verticesStored" ]
1130- aStat ["graphStoreStatus" ] = gsStat
1131- if "allGssStatus" in aggregatedStatus :
1132- allGssStatus = aggregatedStatus ["allGssStatus" ]
1133- agStat : Json = {}
1134- if "items" in allGssStatus :
1135- items = allGssStatus ["items" ]
1136- itemList : List [Json ] = []
1137- for i in items :
1138- ri : Json = {}
1139- if "verticesProcessed" in i :
1140- ri ["verticesProcessed" ] = i ["verticesProcessed" ]
1141- if "messagesSent" in i :
1142- ri ["messagesSent" ] = i ["messagesSent" ]
1143- if "messagesReceived" in i :
1144- ri ["messagesReceived" ] = i ["messagesReceived" ]
1145- if "memoryBytesUsedForMessages" in i :
1146- ri ["memoryBytesUsedForMessages" ] = i [
1147- "memoryBytesUsedForMessages"
1148- ]
1149- itemList .append (ri )
1150- agStat ["items" ] = itemList
1151- aStat ["allGssStatus" ] = agStat
1152- d [aggregatedStatus ] = aStat
1153- result ["detail" ] = d
1110+ result ["detail" ] = body ["detail" ]
11541111
11551112 if "aggregators" in body :
11561113 result ["aggregators" ] = body ["aggregators" ]
0 commit comments