with raise_on_exception():
	makeNode_flow = Flow("Make Node", state_handlers=[visualize])
	
	# Munge API definition responses
	munge_result = mng.munge_dfs([df1, df2, df3])
	
	flow.set_dependencies(
		task=mng.munge_dfs,
		upstream_tasks=[api1(), api2(lang='en')],
		keyword_tasks=dict(term='bit',
						  topic='computer science'))