Arthur
02/03/2023, 4:27 PMupdate_sensor = build_asset_reconciliation_sensor(
name="update_sensor",asset_selection=AssetSelection.keys("update_broker"),
minimum_interval_seconds = 30,
description = "Update sensor to trigger Broker Quotings update"
)
with the asset defined as
@asset(io_manager_key="snowflake_query_manager",non_argument_deps={"broker_quotings_ingest"},
group_name='stream_data',compute_kind='snowflake',freshness_policy=FreshnessPolicy(maximum_lag_minutes=2))
def update_broker(context):
jamie
02/03/2023, 5:46 PMupdate_broker
asset un-materialized?Arthur
02/03/2023, 7:55 PM