Daniel Mosesson
03/13/2023, 9:11 AMJakub Zgrzebnicki
03/13/2023, 9:30 AM@asset(
key_prefix=KEY_PREFIX,
ins={
'types_mapping': AssetIn(
key=[KEY_PREFIX, 'types_mapping'],
partition_mapping=LastPartitionMapping()
)
}
)
Daniel Mosesson
03/13/2023, 9:47 AMJakub Zgrzebnicki
03/13/2023, 9:49 AMDaniel Mosesson
03/13/2023, 9:55 AMJakub Zgrzebnicki
03/13/2023, 9:56 AMDaniel Mosesson
03/13/2023, 9:56 AMin
for the graph backed part, and then passed it as a param to the opJakub Zgrzebnicki
03/13/2023, 9:57 AMDaniel Mosesson
03/13/2023, 10:00 AM@asset
def asset1():
...
@op
def op1(asset1):
....
@graph_asset(
partitions_def=HourlyPartition(...),
ins = {
'asset1': AssetIn('asset1', partition_mapping = LastPartitionMapping())
}
)
def g1(asset1):
op1(asset1)
Sorry for the retype, I can't copy and paste from the environmentJakub Zgrzebnicki
03/13/2023, 10:07 AMDaniel Mosesson
03/13/2023, 10:15 AM