Skip to content

Commit 4f802d9

Browse files
committed
PNDA-4012: Top level component type added
1 parent e1d37f2 commit 4f802d9

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

api/src/main/resources/application_summary.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -281,6 +281,7 @@ def oozie_coordinator_handler(data):
281281
coord_status.update({'actions': oozie_data, 'status': aggregate_status, 'aggregate_status':\
282282
'%s_%s_%s' % (ApplicationState.COMPLETED, 'KILLED', FAILURE_STATUS[aggregate_status]), \
283283
'oozieId': data['coordJobId'], 'name': data['coordJobName']})
284+
coord_status.update({"componentType": "Oozie"})
284285
return coord_status
285286

286287
def oozie_workflow_handler(data):
@@ -309,6 +310,7 @@ def oozie_workflow_handler(data):
309310
workflow_status.update({'actions': oozie_data, 'aggregate_status': '%s_%s_%s' % \
310311
(ApplicationState.COMPLETED, 'KILLED', FAILURE_STATUS[aggregate_status]), \
311312
'oozieId': data['id'], 'name': data['appName'], 'status': aggregate_status})
313+
workflow_status.update({"componentType": "Oozie"})
312314
return workflow_status
313315

314316
def oozie_application(job_handle):
@@ -394,6 +396,7 @@ def spark_application(job_name):
394396
'information': information,
395397
'name': job_name
396398
}
399+
ret.update({"componentType": "SparkStreaming"})
397400
return ret
398401

399402
def get_json(component_list, queue_obj):

0 commit comments

Comments
 (0)