Binh Pham
08/11/2020, 9:06 PMwith open("./project/environments/solids.yaml") as f:
solid_names = yaml.full_load(f)["solids"]
@pipeline(
preset_defs=[
PresetDefinition.from_pkg_resources(
"dev_run",
pkg_resource_defs=["project.environments", "solids.yaml"]
)
]
)
def pipeline_a():
for sn in solid_names:
my_solid.alias(sn)()