fanout.md
In maestro: Orchestration of Data Pipelines

Simple fan out with no specified iterator

Code
  status[, c("invoked", "success")]
Output
  # A tibble: 4 x 2
    invoked success
    <lgl>   <lgl>  
  1 TRUE    TRUE   
  2 TRUE    TRUE   
  3 TRUE    TRUE   
  4 TRUE    TRUE

Simple fan out into common downstream

Code
  status[, c("invoked", "success")]
Output
  # A tibble: 7 x 2
    invoked success
    <lgl>   <lgl>  
  1 TRUE    TRUE   
  2 TRUE    TRUE   
  3 TRUE    TRUE   
  4 TRUE    TRUE   
  5 TRUE    TRUE   
  6 TRUE    TRUE   
  7 TRUE    TRUE

Simple fan out into common downstream and one error

Code
  status[, c("invoked", "success")]
Output
  # A tibble: 6 x 2
    invoked success
    <lgl>   <lgl>  
  1 TRUE    TRUE   
  2 TRUE    FALSE  
  3 TRUE    TRUE   
  4 TRUE    TRUE   
  5 TRUE    TRUE   
  6 TRUE    TRUE

Use maestroMap to specify a particular iteration variable

Code
  status[, c("invoked", "success")]
Output
  # A tibble: 4 x 2
    invoked success
    <lgl>   <lgl>  
  1 TRUE    TRUE   
  2 TRUE    TRUE   
  3 TRUE    TRUE   
  4 TRUE    TRUE

Fan out where upstream returns a list of S3 objects (lm)

Code
  status[, c("invoked", "success")]
Output
  # A tibble: 4 x 2
    invoked success
    <lgl>   <lgl>  
  1 TRUE    TRUE   
  2 TRUE    TRUE   
  3 TRUE    TRUE   
  4 TRUE    TRUE

Fan where the field contains S3 objects (lm)

Code
  status[, c("invoked", "success")]
Output
  # A tibble: 4 x 2
    invoked success
    <lgl>   <lgl>  
  1 TRUE    TRUE   
  2 TRUE    TRUE   
  3 TRUE    TRUE   
  4 TRUE    TRUE

map is misspecified name in return

Code
  status[, c("invoked", "success")]
Output
  # A tibble: 2 x 2
    invoked success
    <lgl>   <lgl>  
  1 TRUE    TRUE   
  2 TRUE    FALSE

Use maestroMap with multiple iterators

Code
  status[, c("invoked", "success")]
Output
  # A tibble: 4 x 2
    invoked success
    <lgl>   <lgl>  
  1 TRUE    TRUE   
  2 TRUE    TRUE   
  3 TRUE    TRUE   
  4 TRUE    TRUE