Ashraf Shaik12/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 ]
all_assets = [*recommender_assets] @repository def flows(): return [ *all_assets ]
owen12/02/2022, 12:25 AM
, 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 Shaik12/02/2022, 12:51 AM