The cloud-native orchestrator for the whole development lifecycle, with integrated lineage and observability.

dagster

I'm trying to use an `observe_fn` for a `SourceAsset` however it is unclear to me how to access the content in order to calculate a `DataVersion`.

I was hoping that the `context` available in the `observe_fn` would be an `InputContext` which would allow me to use an `IOManager` to access the `Asset`.

However, the `context` is an `OpExecutionContext` and I can't work out how to get an `InputContext` from this.

Does anyone know how this is supposed to work?

But, alas, it does not. Any help would be really appreciated!