|
@@ -262,7 +262,7 @@ def list_oozie_coordinator(request, job_id):
|
|
|
except:
|
|
except:
|
|
|
pass
|
|
pass
|
|
|
|
|
|
|
|
- show_all_actions =request.GET.get('show_all_actions') == 'true'
|
|
|
|
|
|
|
+ show_all_actions = request.GET.get('show_all_actions') == 'true'
|
|
|
|
|
|
|
|
if request.GET.get('format') == 'json':
|
|
if request.GET.get('format') == 'json':
|
|
|
actions = massaged_coordinator_actions_for_json(oozie_coordinator, oozie_bundle)
|
|
actions = massaged_coordinator_actions_for_json(oozie_coordinator, oozie_bundle)
|
|
@@ -689,11 +689,11 @@ def massaged_coordinator_actions_for_json(coordinator, oozie_bundle):
|
|
|
actions = []
|
|
actions = []
|
|
|
|
|
|
|
|
related_job_ids = []
|
|
related_job_ids = []
|
|
|
|
|
+ related_job_ids.append('coordinator_job_id=%s' % coordinator_id)
|
|
|
if oozie_bundle is not None:
|
|
if oozie_bundle is not None:
|
|
|
related_job_ids.append('bundle_job_id=%s' %oozie_bundle.id)
|
|
related_job_ids.append('bundle_job_id=%s' %oozie_bundle.id)
|
|
|
|
|
|
|
|
for action in coordinator_actions:
|
|
for action in coordinator_actions:
|
|
|
- related_job_ids.append('coordinator_job_id=%s' % coordinator_id)
|
|
|
|
|
massaged_action = {
|
|
massaged_action = {
|
|
|
'id': action.id,
|
|
'id': action.id,
|
|
|
'url': action.externalId and reverse('oozie:list_oozie_workflow', kwargs={'job_id': action.externalId}) + '?%s' % '&'.join(related_job_ids) or '',
|
|
'url': action.externalId and reverse('oozie:list_oozie_workflow', kwargs={'job_id': action.externalId}) + '?%s' % '&'.join(related_job_ids) or '',
|