I m using the `build asset reconciliation sensor` where the dagster #ask-community

I'm using the `build_asset_reconciliation_sensor` ...

Rafael Gomes

01/18/2023, 7:37 PM

I'm using the

build_asset_reconciliation_sensor

where the upstream assets are "partitioned" but the sensor is not being triggered and the asset is "stale". What could be happening? It does show the upstream jobs properly. There is this message "Sensor function returned an empty result"

Rafael Gomes

01/18/2023, 7:43 PM

Screenshot 2023-01-18 at 4.40.12 PM.png

Rafael Gomes

01/18/2023, 7:44 PM

This is the code I have (just changed the asset name to X):

Copy code

sync_reconcilliation = build_asset_reconciliation_sensor(
            asset_selection=AssetSelection.keys("X"),
            name="asset_reconciliation_sensor",
        )

Rafael Gomes

01/18/2023, 7:49 PM

Also, the cursor keeps changing to arbitrary values.

sandy

01/19/2023, 7:50 PM

Hey @Rafael Gomes- are you using static partitions or daily/weekly/hourly partitions?

sandy

01/19/2023, 7:51 PM

Was asset X updated less recently than the assets above it? I'm wondering if this could be a problem with the "Stale" status and not a problem with the reconciliation sensor

Rafael Gomes

01/19/2023, 9:29 PM

The upstream assets are multi-partitioned. Asset X wasn't updated less recently than upstream. I end up using a

multi_asset_sensor

sandy

01/21/2023, 1:16 AM

got it - our next release includes a bugfix related to multi-partitions and the asset reconciliation sensor. it might fix this issue. if you try it again after that release and it's still not fixed, let me know and I can investigate further.

6 Views

Open in Slack

Previous Next