geoHeil
02/24/2023, 11:56 AMVinnie
02/24/2023, 12:28 PMruntime_metadata_fn
parameter in load_assets_from_dbt_*
. I’m not sure if that generates an AssetObservation, but it would add to the metadata returned.Andrea
02/24/2023, 4:08 PMruntime_metadata_fn
for dbt projects would go a long way.Vinnie
02/24/2023, 4:10 PMclaire
02/24/2023, 5:51 PMhandle_output
method, you could do context.log_event(AssetObservation(...))
geoHeil
02/28/2023, 7:58 AMclaire
02/28/2023, 11:50 PMfrom dagster import IOManager, AssetMaterialization
class MyIOManager(IOManager):
def handle_output(self, context, obj):
context.log_event(AssetMaterialization("foo"))
I agree that this pattern would be helpful to document in the docs though. We also have a similar utility that attaches observations via the load_input
method of an IO manager. I'd recommend filing an issue so that we can track adding this to our documentationgeoHeil
03/01/2023, 8:28 AM