Data Catalog Options Generator

catalog.yml

pipeline.py

node(
	func=combine_users,
	inputs=["prm_accounts", "prm_users"],
	outputs="combined_users",
	name="combine_users_node",
),

node(
	func=create_model_input_table,
	inputs=["combined_users", "prm_calls", "prm_disputes"],
	outputs="model_input_table",
	name="create_model_input_table_node",
)