run_pipeline {condusco}

Runs user-provided pipeline for each row of arguments in parameters, converting any JSON strings to objects

Description

Runs user-provided pipeline for each row of arguments in parameters, converting any JSON strings to objects

Usage

run_pipeline(pipeline, parameters)

Arguments

pipeline

User-provided function with one argument, a dataframe

parameters

An dataframe of fields to convert to json

Examples

library(whisker)

run_pipeline(
  function(params){
   query <- "SELECT result FROM {{table_prefix}}_results;"
   whisker.render(query,params)
 },
 data.frame(
   table_prefix = c('batman', 'robin')
 )
)