robsyme

workflow {
    def statham = new groovy.json.JsonSlurper()

    updates = Channel.topic('model_updates')
    limit = updates.until { path -> statham.parseText(path.text).score >= 100 }
    
    Setup()
    Model(updates, limit)
    
    Model.out.last().view { model -> "Last model: ${model.text}" }

robsyme

nextflow.preview.topic = true

workflow {
    def statham = new groovy.json.JsonSlurper()

    Channel.topic('model_updates')
        .tap { updates }
        .map { path -> statham.parseText(path.text) }
        .until { obj -> obj?.score > 100 }
        .tap { limit }

robsyme

#!/usr/bin/env nextflow
nextflow.preview.output = true
/*
 * Pipeline parameters
 */

// Primary input (file of input files, one per line)
params.reads_bam = "${projectDir}/data/sample_bams.txt"

// Output directory

robsyme

>HWR61437.1 MAG TPA: tetrahydromethanopterin S-methyltransferase subunit E, partial [Clostridia bacterium]
ALMGAAATIAGAAEDLESDIGSMSNPNSQVQLAPQMGHLHRMFNKAISGEPVQMGTLAGIAGSVAYVLIG
SVHLPVIMSIAAGGFIAALFHTAFATTSYLGRIVGQSQFNQPVFMDVITSHLGPIAAHGFIVTFCIVGLS
YLMNTVLQPTHPFPLPLLAVLWGITIGAIGSSTGDVHYGAEREYQTYPFGGGIPVAIHGDITTKAELGAR
NSIDVVHFCAKFGGPVTGFCFGLIVFLSFWVTVVFGPTGGVIAGLVIILLLIILNNRIEIFARNSYGPYK
E

robsyme

#!/usr/bin/env nextflow

params.outdir = 'results'
params.all = false

workflow {
    First()

    First.out.value | Second
    Second.out.value | Third

robsyme

#!/usr/bin/env nextflow

params.outdir = 'results'
params.all = false

workflow {
    First()

    First.out.value | Second
    Second.out.value | Third

robsyme

process A {
    input: val(name)
    output: tuple val(name), path("*")
    script: "echo hello $name > greeting.${name}.txt"
}

process B {
    input: val(name)
    output: tuple val(name), path("*")
    script: "echo goodbye $name > farewell.${name}.txt"

robsyme

#!/usr/bin/env nextflow
nextflow.enable.dsl=2
nextflow.preview.recursion=true

params.input = 'data/*.dat'

process ScannerLightly {
    input:
    path datfile_accumulator
    val meta_accumulator

robsyme

#!/usr/bin/env ruby

require 'json'
require 'optparse'

options = {}
OptionParser.new do |opt|
  opt.on('--report FILENAME') { |report| options[:report] = report } 
end.parse!

robsyme

process A {
    input:
    val(i)

    output:
    path("output.${i}.txt")

    "echo hello $i > output.${i}.txt"
}