Ashraf Shaik
12/02/2022, 12:08 AM@asset(group_name=RECOMMENDER)
def asset_1()
@asset(group_name=RECOMMENDER)
def asset_2(asset_1)
story_recommender_job = define_asset_job("story_recommender_job"
, selection=AssetSelection.groups(RECOMMENDER))
all_jobs = [story_recommender_job]
@repository
def flows():
return [ *all_jobs ]
Vs
all_assets = [*recommender_assets]
@repository
def flows():
return [ *all_assets ]
owen
12/02/2022, 12:25 AMdefine_asset_job
, that AssetSelection is relative to all of the asset definitions that exist in the repository, so in your first example, that story_recommender_job actually would not contain any assets (as the assets don't exist in the repository, because they're not in the list returned from the flows function).Ashraf Shaik
12/02/2022, 12:51 AM