Kevin Schaich
03/06/2023, 1:11 AMDynamicPartitionsDefinition
directly in an asset (without a sensor)? e.g. something like:
images_partitions_def = DynamicPartitionsDefinition(name="images")
@asset(partitions_def=images_partitions_def)
def images(context):
...
images = get_data()
for image in images:
images_partitions_def.add_partition(image.name)
yield Output(image, partition=image.name)
Vinnie
03/06/2023, 10:44 AMsandy
03/07/2023, 3:49 AM