Skip to content

Commit 787d964

Browse files
authored
Merge pull request #61 from dharaneeshvrd/PNDA-4012
PNDA-4012: Top level component type added in Application detailed summary
2 parents 2e4352a + 4a0f929 commit 787d964

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
@@ -288,6 +288,7 @@ def oozie_coordinator_handler(data):
288288
aggregate_status = process_component_data(oozie_data)
289289
coord_status.update({'actions': oozie_data, 'status': aggregate_status, 'aggregate_status': 'COMPLETED_WITH_FAILURES', \
290290
'oozieId': data['coordJobId'], 'name': data['coordJobName']})
291+
coord_status.update({"componentType": "Oozie"})
291292
return coord_status
292293

293294
def oozie_workflow_handler(data):
@@ -326,6 +327,7 @@ def oozie_workflow_handler(data):
326327
aggregate_status = process_component_data(oozie_data)
327328
workflow_status.update({'actions': oozie_data, 'aggregate_status': 'COMPLETED_WITH_FAILURES', \
328329
'oozieId': data['id'], 'name': data['appName'], 'status': aggregate_status})
330+
workflow_status.update({"componentType": "Oozie"})
329331
return workflow_status
330332

331333
def oozie_application(job_handle):
@@ -409,6 +411,7 @@ def spark_application(job_name):
409411
'information': information,
410412
'name': job_name
411413
}
414+
ret.update({"componentType": "SparkStreaming"})
412415
return ret
413416

414417
def get_json(component_list, queue_obj):

0 commit comments

Comments
 (0)