compress_pipeline.cwl

class: Workflow
cwlVersion: v1.0
id: compress_pipeline_cwl
label: compress_pipeline.cwl
inputs:
  - id: flag_autocorrelation
    type: boolean?
  - id: surls
    type: 'string[]'
outputs:
  - id: output
    outputSource:
      - inspect_flagging_dataloss/output
    type: 'File[]'
  - id: logfile
    outputSource:
      - dppp/logfile
    type:
      type: array
      items:
        items: File
        type: array
  - id: compressed
    outputSource:
      - compress/compressed
    type: File[]
steps:
  - id: surl_copy
    in:
      - id: surl
        source: surls
    out:
      - id: output
    run: steps/surl_copy.cwl
    label: surl_copy
    scatter:
      - surl
  - id: untar
    in:
      - id: tar_file
        source: surl_copy/output
    out:
      - id: uncompressed
    run: steps/untar.cwl
    label: untar
    scatter:
      - tar_file
  - id: dppp
    in:
      - id: parset
        source: define_parset/output
      - id: msin
        source: untar/uncompressed
      - id: msout_name
        source: untar/uncompressed
        valueFrom: '$("COMPRESSED_" + self[0].basename)'
      - id: writefullresflag
        default: true
      - id: storagemanager
        default: Dysco
      - id: databitrate
        default: 10
    out:
      - id: msout
      - id: logfile
    run: steps/DPPP.cwl
    scatter:
      - msin
  - id: define_parset
    in:
      - id: flag_autocorrelation
        source: flag_autocorrelation
    out:
      - id: output
    run: steps/define_parset.cwl
    label: define_parset
  - id: inspect_flagging_dataloss
    in:
      - id: input
        source: untar/uncompressed
    out:
      - id: output
    run: steps/inspect_flagging_dataloss.cwl
    label: inspect_flagging_dataloss
    scatter:
      - input
  - id: compress
    in:
      - id: directory
        source: dppp/msout
    out:
      - id: compressed
    run: steps/compress.cwl
    label: compress
    scatter:
      - directory
requirements:
  - class: ScatterFeatureRequirement