with Flow("Make Node") as f:

	x_lst = Parameter("x_lst")
	input_df = Parameter("input_df")
	
	
	# Do something with x
	n_nodes = x_lst.value_count().max()
	
	"""
	This does not seem correct. How does merge work with this workflow?
	"""
	prefect.tasks.control_flow.conditional.ifelse(
		n_nodes>1,
		new_df = cluster(input_df),
		new_df = input_df
	)
	prefect.tasks.control_flow.conditional.ifelse(
		some_str is "short",
		new_df1 = do_something(new_df),
		new_df1 = do_something_else(new_df)
	)
	
	kwrds_df = ge_keywords(new_df1)