Ajita Khanal
04/21/2023, 8:24 AM@asset(
partitions_def=StaticPartitionsDefinition(partition_keys=get_my_list()),
)
def process_output(context):
partition_string = context.asset_partition_key_for_output()
return partition_string
defs = Definitions(
assets=[process_output],
)
Sean Lopp
04/21/2023, 2:52 PMAjita Khanal
04/21/2023, 3:13 PM