Thomas Monk
07/01/2023, 11:18 AMJustin Taylor
07/01/2023, 11:58 AMDynamicOut(put)
objects in Dagster to do computation on sub-units of the data, while keeping the assets partitioned with the same partition definition. I also use an asset_sensor
to trigger materializations of a downstream asset after a dynamic partition in the upstream asset is materialized, as I haven't had the best luck using AutoMaterializePolicy
with our dynamically-partitioned assets.
https://docs.dagster.io/concepts/ops-jobs-graphs/dynamic-graphs#dynamic-graphs
https://docs.dagster.io/concepts/partitions-schedules-sensors/asset-sensorsThomas Monk
07/03/2023, 3:41 PM