dagster是否支持没有输出的固体之间的依赖关系？

Question

我正在构建一个原型管道，它可以做两件事：

现有directory

• (solid)中的

1. (solid) Clears文件运行一个批处理过程，将数据转储到该目录.

第一步完全是副作用，没有输出传递到第二步。在管道中，这两种固体之间的依赖能表达出来吗？

Answer 1

我认为来自https://docs.dagster.io/examples/nothing的以下代码片段应该适用于您的用例：

from dagster import Nothing

@solid
def create_table_1(_) -> Nothing:
    get_database_connection().execute("create table_1 as select * from some_source_table")


@solid(input_defs=[InputDefinition("start", Nothing)])
def create_table_2(_):
    get_database_connection().execute("create table_2 as select * from table_1")


@pipeline
def my_pipeline():
    create_table_2(create_table_1())