我正试图从我的Python代码中以编程方式启动Dagster作业。到目前为止，我已经准备好使用python客户端启动一个具有默认或完全指定配置的作业。我遇到的问题是没有能力问Dagster配置模式是什么。有没有一种方法可以通过API导入模式，这样我就不需要硬编码了？
unftdfkk1#
如果您尝试检索配置值，则可以在op/asset/resource定义中使用以下内容：对于操作或资产：context.op_config["<config_name>"]@op示例：
context.op_config["<config_name>"]
@op
@op(config_schema={"person_name": str})def op_using_config(context): return f'hello {context.op_config["person_name"]}'
@op(config_schema={"person_name": str})
def op_using_config(context):
return f'hello {context.op_config["person_name"]}'
对于资源：context.resource_config["<config_name>"]如果你想定义配置值，你可以用三种方法：通过Python代码或通过YAML文件。你可以查一下官方文件。
context.resource_config["<config_name>"]
1条答案
按热度按时间unftdfkk1#
如果您尝试检索配置值，则可以在op/asset/resource定义中使用以下内容：
对于操作或资产：
context.op_config["<config_name>"]@op示例：对于资源：
context.resource_config["<config_name>"]如果你想定义配置值，你可以用三种方法：通过Python代码或通过YAML文件。你可以查一下官方文件。