|
@@ -3779,7 +3779,7 @@ def _save_workflow(workflow, layout, user, fs=None):
|
|
|
Document.objects.link(workflow_doc, owner=workflow_doc.owner, name=workflow_doc.name, description=workflow_doc.description, extra='workflow2')
|
|
Document.objects.link(workflow_doc, owner=workflow_doc.owner, name=workflow_doc.name, description=workflow_doc.description, extra='workflow2')
|
|
|
|
|
|
|
|
# Excludes all the sub-workflow and Hive dependencies. Contains list of history and coordinator dependencies.
|
|
# Excludes all the sub-workflow and Hive dependencies. Contains list of history and coordinator dependencies.
|
|
|
- workflow_doc.dependencies = workflow_doc.dependencies.exclude(Q(is_history=False) & Q(type__in=['oozie-workflow2', 'query-hive', 'query-java']))
|
|
|
|
|
|
|
+ workflow_doc.dependencies.set(workflow_doc.dependencies.exclude(Q(is_history=False) & Q(type__in=['oozie-workflow2', 'query-hive', 'query-java'])))
|
|
|
|
|
|
|
|
dependencies = \
|
|
dependencies = \
|
|
|
[node['properties']['workflow'] for node in workflow['nodes'] if node['type'] == 'subworkflow-widget'] + \
|
|
[node['properties']['workflow'] for node in workflow['nodes'] if node['type'] == 'subworkflow-widget'] + \
|