V15 Orchestrate named steps

Use your current course session. Preparation and course runner · R script ↓

Optional deep dive. Enable only the options named in each block, after preparing its packages or services.

V15 Orchestrate named steps

Goal: Express dependencies through function arguments.

Prerequisites: H07; extras.

The current dr_workflow form uses named functions to define a sequential dependency graph. The old empty builder is not used.

training_step(
  "V15",
  {
    training_flow <- dr_workflow(
      checked = function(delivery) {
        dr_run(policy_product, data = delivery, write = FALSE)
      },
      total = function(checked) sum(dr_collect(checked)$premium),
      inputs = list(delivery = policies),
      code_version = "training-flow-v1"
    )
    flow_first <- dr_run(training_flow)
    print(flow_first$status)
    stopifnot(flow_first$results$total == 740)
  },
  needs = c("H07"),
  enabled = training_options$extras,
  optional = TRUE
)

Expected result: checked runs before total; the total is 740.

Task: Is this a scheduler?