1616 "serviceClass": "ServiceClass", /* The service class of the service launching the JOB */
1717 "callerQualifier": "TOKEN",
1818 "consumerId": "<USERNAME>",
19- "aggregated": true ,
19+ "aggregated": false ,
2020 "serviceName": "ServiceName", /* The service name of the service launching the JOB */
2121 "duration": 376,
2222 "maxInvocationTime": 376,
@@ -135,7 +135,6 @@ def update_pod_metric(self, pod, metrics, period_start, period_end):
135135 )
136136
137137 def generate_record (self , pod ):
138- # Fields that we are not considering right now:
139138 # minInvocationTime
140139 # maxInvocationTime
141140 if not pod .flavor :
@@ -159,12 +158,14 @@ def generate_record(self, pod):
159158 "serviceClass" : service_class ,
160159 "callerQualifier" : "TOKEN" ,
161160 "consumerId" : pod .global_user_name ,
162- "aggregated" : True ,
161+ "aggregated" : False ,
163162 "serviceName" : service_name ,
164163 "scope" : pod .fqan ,
165164 "host" : self .host ,
166165 "id" : str (pod .local_id ),
167166 "duration" : int (pod .wall ),
167+ "minInvocationTime" : int (pod .wall ),
168+ "maxInvocationTime" : int (pod .wall ),
168169 # these are in miliseconds
169170 "startTime" : int (pod .start_time .timestamp () * 1000 ),
170171 "endTime" : int (pod .end_time .timestamp () * 1000 ),
0 commit comments