You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Hello guys, I’m currently making a multi asset sensor. This sensor depends on asset A and B, both partitions by hour. I would like to trigger the downstream if there is partition A and the last 24h of partition B.
My idea was to make like the example:
run_requests= []
for (
partition,
materializations_by_asset,
) incontext.latest_materialization_records_by_partition_and_asset().items():
ifset(materializations_by_asset.keys()) ==set(context.asset_keys):
# Get last 24h of run if successrun_requests.append(RunRequest(partition_key=partition))
forasset_key, materializationinmaterializations_by_asset.items():
context.advance_cursor({asset_key: materialization})
returnrun_requests
But before doing the request I would check if the last 24h run succeed. Do you know if there is a better way? If not do you know how I can check last 24h run status based on a partition ?
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
Hello guys, I’m currently making a multi asset sensor. This sensor depends on asset A and B, both partitions by hour. I would like to trigger the downstream if there is partition A and the last 24h of partition B.
My idea was to make like the example:
But before doing the request I would check if the last 24h run succeed. Do you know if there is a better way? If not do you know how I can check last 24h run status based on a partition ?
Beta Was this translation helpful? Give feedback.
All reactions