clay
02/15/2023, 3:43 PM@asset()
somehow?
I tried adding the following to @asset
and had the same error:
ins={"my_asset": AssetIn("my_asset", dagster_type=MyDataFrame)}
The only way I'm able to load my_asset
in my_downstream_asset
is with the signature:
def my_downstream_asset(context: OpExecutionContext, my_asset: pd.DataFrame) -> None:
....
... or, is the metadata about the MyDataFrame type stored in the dagster postgres db so that the types automatically are applied? 🤔