How is workflow(pro) implemented?

[geekodour]

Now, It's perfectly fine if this question is non-answerable!

I was just curious how is the DAG structure maintained when we directly pass result.Jobs into insertMany.

One could use priority but that'll not always work (eg. C and D depend on A and B respectively and we don't know in advance if A or B will finish first, so someone will be waiting).

  // Prepare the workflow for insertion and validate it:
    result, err := riverworkflow.Prepare(ctx, riverClient, SampleWorkflow())
    if err != nil {
        panic(err)
    }

    // The result.Jobs field holds a slice of river.InsertManyOpts which can be
    // enqueued with a riverClient.InsertMany / InsertManyTx call:
    if _, err := riverClient.InsertMany(ctx, result.Jobs); err != nil {
        panic(err)
    }