Adam Ward
01/13/2023, 9:31 PMget_asset_value_loader
without encountering the circular dependencies error?owen
01/13/2023, 10:50 PM@op
def foo():
from ..repository import my_repo
with my_repo.get_asset_value_loader() as loader:
...
Adam Ward
01/14/2023, 12:26 AMget_asset_value_loader
function to get the latest run_id and determine whether the given asset is reconciled or not. 🤞🏻owen
01/14/2023, 12:29 AMget_asset_value_loader
is the right tool for the job here actually. It just loads the actual value of the asset as an in-memory object. We are planning at some point to add a batch_freshness_policy_sensor
which would run for all selected assets at once, but that work isn't planned for the immediate futureAdam Ward
01/14/2023, 12:32 AMowen
01/14/2023, 12:33 AMAdam Ward
01/14/2023, 12:33 AMowen
01/14/2023, 12:34 AM@sensor
, then use the instance queryer to calculate the status of each of your assets (and use that to create some config dictionary that you add to your RunRequest for the email job)Adam Ward
01/14/2023, 12:36 AM