https://dagster.io/ logo
#ask-community
Title
# ask-community
a

Arthur

02/03/2023, 4:27 PM
Hi all, would anyone know why I would get this result with a sensor - Sensor Function returned an empty result
update_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):
it would appear asset_reconcilliation is not fond of upstream inputs? or non argument deps. It works if I remove them
j

jamie

02/03/2023, 5:46 PM
just to confirm - did this skipped result happen after you had materialized the upstream assets, but left the
update_broker
asset un-materialized?
a

Arthur

02/03/2023, 7:55 PM
yep, I'll try again on a clean slate for more details