Kate Ross
05/04/2023, 10:09 AMVinnie
05/04/2023, 10:33 AMKate Ross
05/04/2023, 10:40 AMVinnie
05/04/2023, 10:48 AMclass MySourceAssetIOManager(ConfigurableIOManager):
def load_input(self, context):
with open("my/asset/path") as f:
return f.read()
SourceAsset("my_source_asset", io_manager_def=MySourceAssetIOManager)
Basically I assume you’d have to find a way to tell your IO Manager where to find the source asset, this could be done with the asset keys or other information you can find within the `InputContext`(https://github.com/dagster-io/dagster/blob/master/python_modules/dagster/dagster/_core/execution/context/input.py#L39)Kate Ross
05/04/2023, 10:49 AM