package main

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

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

    targetExtractor := spc.NewCommandToParams(wf, "cmdtoparam", `awk '{ 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()
}