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

Nick Centola

03/24/2023, 7:18 PM
Is it possible to use the asset reconciliation sensor when you have cross code location asset dependencies? We have two locations (say location A & location B). Location A produces raw data assets, location B runs dbt transformations The reconciliation sensor is defined in location B:
Copy code
build_asset_reconciliation_sensor(
    name = "freshness_sensor",
    asset_selection = AssetSelection.all()
)
Some assets in location B are downstream of assets from location A. The sensor is not able to reconcile the upstream assets from location A and fails with traceback:
Copy code
KeyError: AssetKey(['location_a', 'some_asset'])
  File "/usr/local/lib/python3.10/site-packages/dagster/_core/errors.py", line 206, in user_code_error_boundary
    yield
  ....
  File "/usr/local/lib/python3.10/site-packages/dagster/_core/definitions/asset_graph.py", line 172, in get_parents
    return self._asset_dep_graph["upstream"][asset_key]
I have tried manually defining the assets from location A as `SourceAsset`s in location B but it doesn't resolve the issue. Is it possible to resolve these cross location assets?
👌 1
j

jamie

03/24/2023, 7:38 PM
hey @Nick Centola, we don’t support this yet, but it’s something we plan to support. here’s the relevant github issue to track https://github.com/dagster-io/dagster/issues/10724
n

Nick Centola

03/24/2023, 7:46 PM
Thanks Jamie, I'll keep an eye on that issue. This would be a super useful feature to have
2 Views