R Lucas
06/14/2023, 8:20 PMmaterialize_to_memory
will fail when selecting set of assets with multiple partition definitions (hourly & daily/monthly).
Is there a solution to implement a test with materiaiize_to_memory
that will materialize upstream hourly assets then downstream daily assets ?owen
06/16/2023, 8:33 PMfrom dagster import InMemoryIOManager
def my_test():
# will be shared across invocations of materialize
shared_io_manager = InMemoryIOManager()
all_assets = [hourly_asset, daily_asset]
for hour in [...]:
materialize(all_assets, resources={"io_manager": shared_io_manager}, partition_key=hour, selection=[hourly_asset])
materialize(all_assets, resources={"io_manager": shared_io_manager}, partition_key=..., selection=[daily_asset])
owen
06/16/2023, 8:33 PMR Lucas
06/19/2023, 8:47 AM