download_and_compress_pipeline.cwl

#!/usr/bin/env cwl-runner

cwlVersion: v1.2
class: Workflow
label: download_and_compress_pipeline

requirements:
- class: ScatterFeatureRequirement
- class: SubworkflowFeatureRequirement
- class: StepInputExpressionRequirement
- class: InlineJavascriptRequirement

inputs:
- id: flag_autocorrelation
  type: boolean?
- id: surls
  type: string[]
- id: is_long_baseline
  type: boolean

outputs:
- id: compressed
  type: File[]
  outputSource:
  - compress/compressed
- id: logfile
  type:
    type: array
    items:
      type: array
      items: File
  outputSource:
  - compress/logfile
- id: ingest
  type: Any[]
  outputSource:
  - compress/ingest
- id: quality
  type: Any
  outputSource:
  - format_quality_metrics/formatted_quality
- id: control
  type: Any
  outputSource:
  - format_quality_metrics/control
- id: inspect
  type: File
  outputSource:
  - combine/inspect_file

steps:
- id: fetch_data
  label: fetch_data
  in:
  - id: surl_link
    source: surls
  scatter:
  - surl_link
  run: steps/fetch_data.cwl
  out:
  - id: uncompressed
- id: compress
  in:
  - id: msin
    source: fetch_data/uncompressed
  - id: flag_autocorrelation
    source: flag_autocorrelation
  - id: is_long_baseline
    source: is_long_baseline
  scatter: