Skip to content
Snippets Groups Projects
Select Git revision
  • compress_tim_survey
  • releases/v0.5.18 protected
  • v0.5.x
  • expose_elevation_for_parset
  • releases/v0.5.17 protected
  • releases/v0.6.0 protected
  • releases/v0.5.19 protected
  • master default protected
  • releases/v0.5.16 protected
  • releases/v0.5.15 protected
  • nico_testing_juelich
  • nightly_build_test
  • releases/v0.5.14 protected
  • releases/v0.5.13 protected
  • releases/v0.5.12 protected
  • releases/v0.5.11 protected
  • numberOfCorrelatedDataProducts
  • releases/v0.5.10 protected
  • releases/v0.5.9 protected
  • releases/v0.5.8 protected
  • v0.5.18
  • v0.5.17
  • v0.6.0
  • v0.5.16
  • v0.5.15
  • v0.5.14
  • v0.5.13
  • v0.5.12
  • v0.5.11
  • v0.5.10
  • v0.5.9
  • v0.5.8
  • v0.5.7
  • v0.5.6
  • v0.5.5
  • v0.5.4
  • v0.5.3
  • v0.5.2
  • v0.5.1
  • v0.5.0
40 results

imaging_compress_pipeline

  • Clone with SSH
  • Clone with HTTPS
  • mancini's avatar
    Mattia Mancini authored
    a1e7e762
    History

    Lofar imaging compression pipeline

    This is a CWL workflow used to compress Lofar imaging data.

    Workflow steps

    Pipeline Overview

    • identify known issues and apply them if necessary. It uses in place updates to prevent copying the measurement set
      • in place update does not work well with CWL conditional steps, so a small bash script is used which either calls the fixing script or does nothing depending if the specific issue for the step was found
    • Compress the measurement set with Dysco
    • Produces inspection plots and collects metrics to quantify the amount of missing/flagged data

    Requirements

    • CWL v1.2 compatible runner (e.g. cwltool/toil)
    • Docker

    Docker images

    • astronsdc/lofar-legacy
    • astronsdc/lofar-ms-software

    Running the workflow

    In the repositories there are two workflows. One is capable to process the data as described in section workflow steps and can be executed as following

    # Run the workflow
    cwltool compress_pipeline.cwl [--flag_autocorrelation] --msin MEASUREMENT_SET

    Another workflow, that is meant to be executed by the LDV infrastructure, takes as an input instead of a measurement set a SURL link of the data. Such a workflow can be execute with the command

    # Run the workflow
    cwltool download_and_compress_pipeline.cwl [--flag_autocorrelation] --surls [list of surl to process] 

    License

    See LICENSE