GJSissons

workflow.onComplete = {
    // any workflow property can be used here
    println "Pipeline complete"
    println "Command line: $workflow.commandLine"
}

workflow.onError = {
    println "Oops .. something when wrong"
}

GJSissons

$ nextflow run <pipeline name> -N <recipient address>

GJSissons

process {

    errorStrategy = { task.exitStatus in ((130..145) + 104) ? 'retry' : 'finish' }
    maxRetries    = 3

    withLabel:process_low {
        cpus   = { check_max( 2     * task.attempt, 'cpus'    ) }
        memory = { check_max( 12.GB * task.attempt, 'memory'  ) }
        time   = { check_max( 4.h   * task.attempt, 'time'    ) }
    }

GJSissons

$ nextflow ./main.nf -profile docker -resume

GJSissons

curl -H "Content-Type: application/json" \
     -H "Authorization: Bearer <YOUR TOKEN>" \
     https://api.tower.nf/actions/6uVJmV5nHSqoBbGIQopRYZ/launch?workspaceId=215559034546785 \
     --data '{"params":{"foo":"Hello world"}}'

GJSissons

$ tw actions list --workspace=seqeralabs/verified-pipelines

  Actions for <tower-user> user:

     ID                     | Name               | Endpoint                                                                               | Status | Source
    ------------------------+--------------------+----------------------------------------------------------------------------------------+--------+--------
     6uVJmV5nHSqoBbGIQopRYZ | LaunchRNASeqFromS3 | https://api.tower.nf/actions/6uVJmV5nHSqoBbGIQopRYZ/launch?workspaceId=215559034546785 | ACTIVE | tower
     7WiIDRY1ymDGUPOnD3IzDN | DemoAction         | https://api.tower.nf/actions/7WiIDRY1ymDGUPOnD3IzDN/launch?workspaceId=215559034546785 | ACTIVE | tower

GJSissons

$ tw actions list –workspace=DataScience/StableDiffusion

GJSissons

$ tw actions add github \
--name=Stable_Diffusion_Webhook \
--labels=huggingface,webhook \
--workspace=DataScience/StableDiffusion \
--compute-env=AWS_Batch_GPU \
--pipeline=https://github.com/evanfloden/stable-diffusion-nf \
--revision=main \
--work-dir=s3://nextflow-bucket-1234/work/

GJSissons

Run at [community / showcase] workspace:

    General
    ---------------------+--------------------------------------------
     ID                  | OLFdDfwJP9W7S
     Operation ID        | 2c1e500d-3d59-4a91-9c39-f22d00c561f4
     Run name            | ridiculous_galileo
     Status              | SUCCEEDED
     Starting date       | Tue, 11 Jul 2023 10:00:41 GMT
     Commit ID           | 3bec2331cac2b5ff88a1dc71a21fab6529b57a0f

GJSissons

#!/bin/bash
export TOWER_API_ENDPOINT=https://api.tower.nf
export TOWER_ACCESS_TOKEN=eyJ0aWQiO********dkNzcxMzUz
export WORKSPACE=`tw workspaces list | grep showcase | awk '{print $1}'`
tw launch --wait=SUCCEEDED --workspace=$WORKSPACE nf-core-rnaseq
export RUN_ID=`tw runs list | grep rnaseq | grep <tower-user> | awk '{print $1}'`
tw runs view --id=$RUN_ID