package main

import (
    sp "github.com/scipipe/scipipe"
    spc "github.com/scipipe/scipipe/components"
)

func main() {
    wf := sp.NewWorkflow("example_workflow", 4)

    // Note that this command does not run in a task-specific sub-folder, since it is not creating any output files directly.
    // ... which means files should not prepended with '../'
    targetExtractor := spc.NewCommandToParams(wf, "cmdtoparam", `awk -f"\t" '{ print $1 }' database | sort | uniq`)

    createDataset := wf.NewProc("create_dataset", `grep "{p:target}" ../database > {o:dataset}`)
    createDataset.SetOut("dataset", "dataset_{p:target}.tsv")
    createDataset.InParam("target").From(targetExtractor.OutParam())

    wf.Run()
}