Skip to contents

This function constructs a new workflow environment for managing and executing steps. The returned object exposes only the public API for workflow operations.

Usage

createWorkflow()

Value

An environment representing the workflow, with public methods as described.

Details

The workflow object provides methods to:

  • List all steps as a data frame (df)

  • Find changed and outdated files (changedAndOutdatedFiles)

  • Create a re-execution plan for outdated steps (createReexecutionPlan)

  • Rerun all changed and outdated steps (rerunChangedAndOutdated)

  • Execute a given execution plan (executePlan)

Internal state and helper functions are encapsulated and not exposed.

Examples

if (FALSE) { # \dontrun{
wf <- createWorkflow()
# Add steps, then:
wf$df()
wf$changedAndOutdatedFiles()
plan <- wf$createReexecutionPlan()
wf$executePlan(plan)
} # }