The cloud-native orchestrator for the whole development lifecycle, with integrated lineage and observability.

dagster

Hi all, forgive me if I missed this in the docs, but I'm using the dagster-dbt API, and I would like to consume the output of one of my models within a Job. Is that possible? Any guidance would be greatly appreciated.

What do you mean by this? Do you want to query the model and use the results in the job?

Do you want to express a "run this job, after this side-effectful action, which does not produce output, has run" dependency?

One sec, resolving docs link from my brain.

```from dagster import In, Nothing, job, op


@op
def create_table_1():
    get_database_connection().execute("create table_1 as select * from some_source_table")


@op(ins={"start": In(Nothing)})
def create_table_2():
    get_database_connection().execute("create table_2 as select * from table_1")


@job
def nothing_dependency():
    create_table_2(start=create_table_1())```

<https://docs.dagster.io/concepts/ops-jobs-graphs/jobs-graphs#order-based-dependencies-nothing-dependencies>

My org hasn't approved DBT, so I'm running bigquery jobs as dagster steps lol.