Binh Pham
03/28/2023, 11:03 PMasset
as an argument to an op
?
Something like
table_a = AsssetIn(["dbt","table_a"])
@op
def my_op(table_a: DataFrame):
table_a.head(10)
Aaron T
03/28/2023, 11:33 PMsean
03/29/2023, 2:37 PMIs it possible to pass an asset as an argument to an op?Yes, see: https://docs.dagster.io/guides/dagster/how-assets-relate-to-ops-and-graphs#op-graphs-that-read-from-an-asset
Binh Pham
03/29/2023, 4:15 PMsean
03/29/2023, 7:14 PMHow can you do this with a dbt asset?Not 100% on this but I think it should still work as long as the op input/arg name matches the asset key of the dbt asset