Asset Factory Example

asset_factory.py

from dagster import asset, Definitions, AssetIn

assets_to_make = ["a", "b", "c"]

def make_assets(asset_to_make):
    @asset(
        name=asset_to_make
    )
    def asset_template():
        print(asset_to_make)
        return 

    return asset_template

factory_assets = [make_assets(key) for key in assets_to_make]


factory_assets_ins = dict(zip(assets_to_make, [AssetIn(i) for i in assets_to_make]))

@asset
def downstream_of_factory_one(a):
    pass

@asset(
    ins=factory_assets_ins
)
def downstream_of_factory_all(**kwargs):
    pass

defs = Definitions(
    assets=[*factory_assets, downstream_of_factory_one, downstream_of_factory_all]
)