Hey y'all I have a job that needs to call 4 ops that run parallel, then run dbt_run_op at the end. It runs dbt_run_op before finishing all the others. I have seen an article that shows how to make ops depend on each other, but it doesn't seem to work with dbt_run_op since it expects a context parameter, and context doesn't seem to get passed in "nested" ops: https://docs.dagster.io/tutorial/ops-jobs/connecting-ops#lets-get-serial

Hi Jayme, I may need to hand this off to someone on our team more knowledgable about our dbt integration, but first-- if you view your job in dagit, does it show the graph structure you would expect (i.e. reflects the dependencies you’re aiming for)?

hi! just at a high level, the structure of your job should look something like:

@job
def my_job():
    dbt_run_op(start_after=[op_a(), op_b(), op_c(), op_d()])

@owen thanks, I've only been using jobs that call individual ops. It looks like this graph is required to create dependencies between ops when there is no input into one I guess?

no problem 🙂