如何从外部dagster加载在dagster中定义的软件资产？

Question

我对dagster来说是个新手，但我真的希望它有从外部dagster加载软件的特性。

为了解释我的要求：

考虑一下这个dagster图：

@asset
def users()->list[int]:
    return [1,2,3]

@asset
def new_users(users)->list[int]:
    return [u for u in users if is_new(u)]

细节并不重要，只是有一些数据会产生一些输出。

在dagster项目之外，我有一些更漂亮的笔记本。我希望能够加载new_users列表。如果我必须为它发明一个API，我会看上去像：

# In some jupyter notebook for example
from dagster.{something} import Project 

project = Project(...)

new_users = project.load_asset(asset='load_asset', force_refresh=False)

达格斯特有这种功能吗？

Answer 1

Dagster有load_asset_value()函数，请参阅https://docs.dagster.io/concepts/assets/software-defined-assets#loading-asset-values-outside-of-dagster-runs下的文档