Oliver
08/01/2022, 11:29 PM@asset(
config_schema={
"limit": int,
"cohort_table": str,
"database": str
},
required_resource_keys={'aws'},
# ins={
# "cohort": AssetIn(
# input_manager_key="pandas_df_manager",
# key=AssetKey(('qld_health', 'qld_health_simple_cohort'))
# )
# },
non_argument_deps={
AssetKey(('qld_health', 'qld_health_simple_cohort'))
}
)
def cohort(context,
# cohort
):
pass
when setting non_argument_deps
to the source asset everything works as expected and the UI shows the correct lineage.
however when trying to supply an argument asset using the ins and the same AssetKey I get Input asset '["qld_health", "qld_health_simple_cohort"]' for asset '["cohort"]' is not produced by any of the provided asset ops and is not one of the provided sources
any ideas what I'm missing here?Oren Lederman
08/01/2022, 11:34 PMOliver
08/01/2022, 11:39 PMowen
08/01/2022, 11:40 PMSourceAsset(key=('qld_health', 'qld_health_simple_cohort'))
to your repository should do the trick, I would think (this would use the default io manager)Oliver
08/01/2022, 11:57 PMinput_manager_key
in the AssetIn definition, whats the difference between setting the io_manager in these two locations?owen
08/02/2022, 12:12 AM