|
@@ -602,8 +602,6 @@ def _dig_nodes(nodes, adj_list, user, wf_nodes, nodes_uuid_set):
|
|
|
elif node['node_type'] == 'email':
|
|
elif node['node_type'] == 'email':
|
|
|
properties['to'] = node.get('email').get('to')
|
|
properties['to'] = node.get('email').get('to')
|
|
|
properties['subject'] = node.get('email').get('subject')
|
|
properties['subject'] = node.get('email').get('subject')
|
|
|
- #TBD: body doesn't show up
|
|
|
|
|
- properties['body'] = node.get('email').get('body')
|
|
|
|
|
elif node['node_type'] == 'streaming':
|
|
elif node['node_type'] == 'streaming':
|
|
|
properties['mapper'] = node.get('streaming').get('mapper')
|
|
properties['mapper'] = node.get('streaming').get('mapper')
|
|
|
properties['reducer'] = node.get('streaming').get('reducer')
|
|
properties['reducer'] = node.get('streaming').get('reducer')
|