@@ -258,35 +258,39 @@ def _populate_prometheus_query_results_from_file(scenario_result,
258
258
scenario_result ['testDurationSeconds' ] = file_query_results [
259
259
'testDurationSeconds' ]
260
260
clientsPrometheusData = []
261
- for client_name , client_data in file_query_results ['clients' ].items (
262
- ):
263
- clientPrometheusData = {'name' : client_name }
264
- containersPrometheusData = []
265
- for container_name , container_data in client_data .items ():
266
- containerPrometheusData = {
267
- 'name' : container_name ,
268
- 'cpuSeconds' : container_data ['cpuSeconds' ],
269
- 'memoryMean' : container_data ['memoryMean' ],
270
- }
271
- containersPrometheusData .append (containerPrometheusData )
272
- clientPrometheusData ['containers' ] = containersPrometheusData
273
- clientsPrometheusData .append (clientPrometheusData )
274
- scenario_result ['clientsPrometheusData' ] = clientsPrometheusData
261
+ if 'clients' in file_query_results :
262
+ for client_name , client_data in file_query_results [
263
+ 'clients' ].items ():
264
+ clientPrometheusData = {'name' : client_name }
265
+ containersPrometheusData = []
266
+ for container_name , container_data in client_data .items ():
267
+ containerPrometheusData = {
268
+ 'name' : container_name ,
269
+ 'cpuSeconds' : container_data ['cpuSeconds' ],
270
+ 'memoryMean' : container_data ['memoryMean' ],
271
+ }
272
+ containersPrometheusData .append (containerPrometheusData )
273
+ clientPrometheusData [
274
+ 'containers' ] = containersPrometheusData
275
+ clientsPrometheusData .append (clientPrometheusData )
276
+ scenario_result ['clientsPrometheusData' ] = clientsPrometheusData
275
277
276
278
serversPrometheusData = []
277
- for server_name , server_data in file_query_results ['servers' ].items (
278
- ):
279
- serverPrometheusData = {'name' : server_name }
280
- containersPrometheusData = []
281
- for container_name , container_data in server_data .items ():
282
- containerPrometheusData = {
283
- 'name' : container_name ,
284
- 'cpuSeconds' : container_data ['cpuSeconds' ],
285
- 'memoryMean' : container_data ['memoryMean' ],
286
- }
287
- containersPrometheusData .append (containerPrometheusData )
288
- serverPrometheusData ['containers' ] = containersPrometheusData
289
- serversPrometheusData .append (serverPrometheusData )
279
+ if 'servers' in file_query_results :
280
+ for server_name , server_data in file_query_results [
281
+ 'servers' ].items ():
282
+ serverPrometheusData = {'name' : server_name }
283
+ containersPrometheusData = []
284
+ for container_name , container_data in server_data .items ():
285
+ containerPrometheusData = {
286
+ 'name' : container_name ,
287
+ 'cpuSeconds' : container_data ['cpuSeconds' ],
288
+ 'memoryMean' : container_data ['memoryMean' ],
289
+ }
290
+ containersPrometheusData .append (containerPrometheusData )
291
+ serverPrometheusData [
292
+ 'containers' ] = containersPrometheusData
293
+ serversPrometheusData .append (serverPrometheusData )
290
294
scenario_result ['serversPrometheusData' ] = serversPrometheusData
291
295
292
296
@@ -329,7 +333,7 @@ def _populate_prometheus_query_results_from_file(scenario_result,
329
333
args .file_to_upload ,
330
334
args .metadata_file_to_upload ,
331
335
args .node_info_file_to_upload ,
332
- args .prometheus_query_results_file )
336
+ args .prometheus_query_results_to_upload )
333
337
print ('Successfully uploaded %s, %s, %s and %s to BigQuery.\n ' %
334
338
(args .file_to_upload , args .metadata_file_to_upload ,
335
339
args .node_info_file_to_upload , args .prometheus_query_results_to_upload ))
0 commit comments