Skip to content
Snippets Groups Projects
Commit db6502fc authored by Mattia Mancini's avatar Mattia Mancini
Browse files

Attempt to fix issue with too many directories

Former-commit-id: 221905e6 [formerly 0667dfd4]
Former-commit-id: 058ccdd8
Former-commit-id: 75573ba5
parent 54865112
Branches
Tags
No related merge requests found
class: CommandLineTool class: CommandLineTool
cwlVersion: v1.0 cwlVersion: v1.0
$namespaces:
sbg: 'https://www.sevenbridges.com/'
id: check_ateam_separation id: check_ateam_separation
baseCommand: baseCommand:
- python3 - python3
......
id: copy_in_one_directory
label: copy_in_one_directory
class: ExpressionTool
cwlVersion: v1.0
inputs:
- id: input
type: Directory[]
outputs:
- id: output
type: Directory
glob: .
requirements:
- class: InitialWorkDirRequirement
listing:
- $(inputs.input)
expression: |
${
}
requirements:
- class: InlineJavascriptRequirement
...@@ -344,9 +344,6 @@ steps: ...@@ -344,9 +344,6 @@ steps:
label: save_results label: save_results
'sbg:x': 1200 'sbg:x': 1200
'sbg:y': 0 'sbg:y': 0
hints:
cwltool:LoadListingRequirement:
loadListing: shallow_listing
requirements: requirements:
- class: SubworkflowFeatureRequirement - class: SubworkflowFeatureRequirement
- class: MultipleInputFeatureRequirement - class: MultipleInputFeatureRequirement
......
...@@ -2,26 +2,19 @@ class: Workflow ...@@ -2,26 +2,19 @@ class: Workflow
cwlVersion: v1.0 cwlVersion: v1.0
id: dowload_surl_and_create_input_file_json id: dowload_surl_and_create_input_file_json
label: dowload_surl_and_create_input_file.json label: dowload_surl_and_create_input_file.json
$namespaces:
sbg: 'https://www.sevenbridges.com/'
inputs: inputs:
- id: surl_list - id: surl_list
type: File type: File
'sbg:x': -329.7890625
'sbg:y': -35
outputs: outputs:
- id: results - id: results
outputSource: outputSource:
- _h_b_a_calibrator/results - _h_b_a_calibrator/results
type: Directory type: Directory
'sbg:x': 739.1641235351562
'sbg:y': -95.5
- id: logs - id: logs
outputSource: outputSource:
- _h_b_a_calibrator/logs - _h_b_a_calibrator/logs
type: Directory type: Directory
'sbg:x': 725.1641235351562
'sbg:y': 153.5
steps: steps:
- id: read_surl_list - id: read_surl_list
in: in:
...@@ -31,8 +24,6 @@ steps: ...@@ -31,8 +24,6 @@ steps:
- id: surls - id: surls
run: ../steps/read_surl_list.cwl run: ../steps/read_surl_list.cwl
label: ReadSurlList label: ReadSurlList
'sbg:x': -158
'sbg:y': -40
- id: surl_copy - id: surl_copy
in: in:
- id: surl - id: surl
...@@ -43,8 +34,6 @@ steps: ...@@ -43,8 +34,6 @@ steps:
label: surl_copy label: surl_copy
scatter: scatter:
- surl - surl
'sbg:x': 145
'sbg:y': -19
- id: untar - id: untar
in: in:
- id: tar_file - id: tar_file
...@@ -55,8 +44,6 @@ steps: ...@@ -55,8 +44,6 @@ steps:
label: untar label: untar
scatter: scatter:
- tar_file - tar_file
'sbg:x': 350
'sbg:y': 8
- id: stage - id: stage
in: in:
- id: input - id: input
...@@ -67,8 +54,6 @@ steps: ...@@ -67,8 +54,6 @@ steps:
label: stage label: stage
scatter: scatter:
- input - input
'sbg:x': -8
'sbg:y': -29
- id: _h_b_a_calibrator - id: _h_b_a_calibrator
in: in:
- id: msin - id: msin
...@@ -79,8 +64,6 @@ steps: ...@@ -79,8 +64,6 @@ steps:
- id: results - id: results
run: ./HBA_calibrator.cwl run: ./HBA_calibrator.cwl
label: HBA_calibrator label: HBA_calibrator
'sbg:x': 563
'sbg:y': 17
requirements: requirements:
- class: SubworkflowFeatureRequirement - class: SubworkflowFeatureRequirement
- class: ScatterFeatureRequirement - class: ScatterFeatureRequirement
......
...@@ -7,147 +7,146 @@ $namespaces: ...@@ -7,147 +7,146 @@ $namespaces:
inputs: inputs:
- id: msin - id: msin
type: 'Directory[]' type: 'Directory[]'
'sbg:x': -1000 'sbg:x': -515.1839599609375
'sbg:y': -900 'sbg:y': 330.674560546875
- id: filter_baselines - id: filter_baselines
type: string type: string
'sbg:x': -1000 'sbg:x': 254.234375
'sbg:y': -800 'sbg:y': 684
- id: raw_data - id: raw_data
type: boolean type: boolean
'sbg:x': -1000 'sbg:x': 0
'sbg:y': -700 'sbg:y': 563
- id: propagatesolutions - id: propagatesolutions
type: boolean type: boolean
'sbg:x': -1000 'sbg:x': 0
'sbg:y': -600 'sbg:y': 670
- id: flagunconverged - id: flagunconverged
type: boolean type: boolean
'sbg:x': -1000 'sbg:x': 559.319091796875
'sbg:y': -500 'sbg:y': 837.5
- id: demix - id: demix
type: boolean type: boolean
'sbg:x': -1000 'sbg:x': 254.234375
'sbg:y': -400 'sbg:y': 1326
- id: max_dppp_threads - id: max_dppp_threads
type: int? type: int?
default: 10 default: 10
'sbg:x': -1000 'sbg:x': 254.234375
'sbg:y': -300 'sbg:y': 214
- id: memoryperc - id: memoryperc
type: int type: int
'sbg:x': -1000 'sbg:x': 254.234375
'sbg:y': -200 'sbg:y': 107
- id: flag_baselines - id: flag_baselines
type: 'string[]' type: 'string[]'
'sbg:x': -1000 'sbg:x': 254.234375
'sbg:y': -100 'sbg:y': 442
- id: avg_timeresolution - id: avg_timeresolution
type: float type: float
'sbg:x': -1000 'sbg:x': 254.234375
'sbg:y': 0 'sbg:y': 1554
- id: avg_freqresolution - id: avg_freqresolution
type: string type: string
'sbg:x': -1000 'sbg:x': 254.234375
'sbg:y': 100 'sbg:y': 1661
- id: process_baselines_cal - id: process_baselines_cal
type: string type: string
'sbg:x': -1000 'sbg:x': 0
'sbg:y': 200 'sbg:y': 777
- id: demix_timestep - id: demix_timestep
type: int type: int
'sbg:x': -1000 'sbg:x': 254.234375
'sbg:y': 300 'sbg:y': 898
- id: demix_freqstep - id: demix_freqstep
type: int type: int
'sbg:x': -1000 'sbg:x': 254.234375
'sbg:y': 400 'sbg:y': 1219
- id: demix_target - id: demix_target
type: string type: string
'sbg:x': -1000 'sbg:x': 254.234375
'sbg:y': 500 'sbg:y': 1005
- id: demix_sources - id: demix_sources
type: 'string[]' type: 'string[]'
'sbg:x': -1000 'sbg:x': 254.234375
'sbg:y': 600 'sbg:y': 1112
- id: min_length - id: min_length
type: int? type: int?
'sbg:x': -1000 'sbg:x': 360
'sbg:y': 700 'sbg:y': 1919.42626953125
- id: overhead - id: overhead
type: float? type: float?
'sbg:x': -1000 'sbg:x': 180
'sbg:y': 800 'sbg:y': 1903.963134765625
- id: min_separation - id: min_separation
type: int? type: int?
'sbg:x': -1000 'sbg:x': 0
'sbg:y': 900 'sbg:y': 884
- id: do_smooth - id: do_smooth
type: boolean? type: boolean?
default: false default: false
'sbg:x': -1000 'sbg:x': 559.319091796875
'sbg:y': 1000 'sbg:y': 944.5
- id: max_separation_arcmin - id: max_separation_arcmin
type: float? type: float?
'sbg:x': -1000 'sbg:x': 0
'sbg:y': 1100 'sbg:y': 991
- id: calibrator_path_skymodel - id: calibrator_path_skymodel
type: Directory? type: Directory?
'sbg:x': -1000 'sbg:x': 0
'sbg:y': 1200 'sbg:y': 1098
- id: A-Team_skymodel - id: A-Team_skymodel
type: File? type: File?
'sbg:x': -1000 'sbg:x': 0
'sbg:y': 1300 'sbg:y': 1205
- id: elevation - id: elevation
type: string type: string
default: 0deg..20deg default: 0deg..20deg
'sbg:x': -1000 'sbg:x': 254.234375
'sbg:y': 1400 'sbg:y': 791
- id: amplmin - id: amplmin
type: float type: float
default: 1.e-30 default: 1.e-30
'sbg:x': -1000 'sbg:x': 254.234375
'sbg:y': 1500 'sbg:y': 1768
outputs: outputs:
- id: outh5parm - id: outh5parm
outputSource: outputSource:
- h5parm_collector/outh5parm - h5parm_collector/outh5parm
type: File type: File
'sbg:x': 1000 'sbg:x': 1554.5106201171875
'sbg:y': -500 'sbg:y': 884
- id: check_Ateam_separation.png - id: check_Ateam_separation.png
outputSource: outputSource:
- check_ateam_separation/output_imag - check_ateam_separation/output_imag
type: File type: File
'sbg:x': 1000 'sbg:x': 559.319091796875
'sbg:y': -300 'sbg:y': 1051.5
- id: msout - id: msout
outputSource: outputSource:
- predict_calibrate/msout - predict_calibrate/msout
type: 'Directory[]' type: 'Directory[]'
'sbg:x': 1000 'sbg:x': 1329.937255859375
'sbg:y': 0 'sbg:y': 663
- id: parset - id: parset
outputSource: outputSource:
- ndppp_prep_cal/parset - ndppp_prep_cal/parset
type: 'File[]' type: 'File[]'
'sbg:x': 1000 'sbg:x': 1027.490966796875
'sbg:y': 200 'sbg:y': 884
- id: calibrator_name - id: calibrator_name
outputSource: outputSource:
- find_skymodel_cal/model_name - find_skymodel_cal/model_name
type: string type: string
'sbg:x': 1000 'sbg:x': 559.319091796875
'sbg:y': 400 'sbg:y': 1158.5
- id: outh5parm_logfile - id: outh5parm_logfile
outputSource: outputSource:
- h5parm_collector/log - h5parm_collector/log
type: File[] type: 'File[]'
'sbg:x': 1000 'sbg:x': 1554.5106201171875
'sbg:y': 650 'sbg:y': 777
- id: logfiles - id: logfiles
linkMerge: merge_flattened
outputSource: outputSource:
- concat_logfiles_calib/output - concat_logfiles_calib/output
- concat_logfiles_predict/output - concat_logfiles_predict/output
...@@ -158,18 +157,23 @@ outputs: ...@@ -158,18 +157,23 @@ outputs:
- make_sourcedb_ateam/log - make_sourcedb_ateam/log
- check_ateam_separation/logfile - check_ateam_separation/logfile
type: 'File[]' type: 'File[]'
'sbg:x': 1000 linkMerge: merge_flattened
'sbg:y': 800 'sbg:x': 1554.5106201171875
'sbg:y': 991
steps: steps:
- id: ndppp_prep_cal - id: copy
in: in:
- id: msin - id: input
linkMerge: merge_flattened
source: source:
- msin - msin
- id: msin_baseline out:
default: '*' - id: output
source: filter_baselines run: ../../steps/copy_in_one_directory.cwl
label: copy_in_one_directory
'sbg:x': -267.1643981933594
'sbg:y': 480.32098388671875
- id: ndppp_prep_cal
in:
- id: baselines_to_flag - id: baselines_to_flag
default: [] default: []
source: source:
...@@ -187,6 +191,13 @@ steps: ...@@ -187,6 +191,13 @@ steps:
- id: demix - id: demix
default: false default: false
source: demix source: demix
- id: msin
linkMerge: merge_flattened
source:
- msin
- id: msin_baseline
default: '*'
source: filter_baselines
- id: skymodel - id: skymodel
source: make_sourcedb_ateam/sourcedb source: make_sourcedb_ateam/sourcedb
- id: timeresolution - id: timeresolution
...@@ -220,8 +231,8 @@ steps: ...@@ -220,8 +231,8 @@ steps:
label: ndppp_prep_cal label: ndppp_prep_cal
scatter: scatter:
- msin - msin
'sbg:x': 0 'sbg:x': 559.319091796875
'sbg:y': 0 'sbg:y': 497.5
- id: predict_calibrate - id: predict_calibrate
in: in:
- id: msin - id: msin
...@@ -246,13 +257,13 @@ steps: ...@@ -246,13 +257,13 @@ steps:
label: predict_calibrate label: predict_calibrate
scatter: scatter:
- msin - msin
'sbg:x': 500 'sbg:x': 1027.490966796875
'sbg:y': 0 'sbg:y': 749
- id: check_ateam_separation - id: check_ateam_separation
in: in:
- id: ms - id: ms
source: source:
- msin - copy/output
- id: min_separation - id: min_separation
source: min_separation source: min_separation
out: out:
...@@ -260,8 +271,8 @@ steps: ...@@ -260,8 +271,8 @@ steps:
- id: logfile - id: logfile
run: ../../lofar-cwl/steps/check_ateam_separation.cwl run: ../../lofar-cwl/steps/check_ateam_separation.cwl
label: check_Ateam_separation label: check_Ateam_separation
'sbg:x': 0 'sbg:x': 254.234375
'sbg:y': -300 'sbg:y': 1440
- id: make_sourcedb_ateam - id: make_sourcedb_ateam
in: in:
- id: sky_model - id: sky_model
...@@ -273,13 +284,13 @@ steps: ...@@ -273,13 +284,13 @@ steps:
- id: log - id: log
run: ../../lofar-cwl/steps/makesourcedb.cwl run: ../../lofar-cwl/steps/makesourcedb.cwl
label: make_sourcedb_ateam label: make_sourcedb_ateam
'sbg:x': -500 'sbg:x': 254.234375
'sbg:y': 300 'sbg:y': 328
- id: find_skymodel_cal - id: find_skymodel_cal
in: in:
- id: msin - id: msin
source: source:
- msin - copy/output
- id: skymodels - id: skymodels
source: calibrator_path_skymodel source: calibrator_path_skymodel
- id: max_separation_arcmin - id: max_separation_arcmin
...@@ -290,8 +301,8 @@ steps: ...@@ -290,8 +301,8 @@ steps:
- id: logfile - id: logfile
run: ../../steps/find_skymodel_cal.cwl run: ../../steps/find_skymodel_cal.cwl
label: find_skymodel_cal label: find_skymodel_cal
'sbg:x': -500 'sbg:x': 254.234375
'sbg:y': 500 'sbg:y': 563
- id: make_sourcedb - id: make_sourcedb
in: in:
- id: sky_model - id: sky_model
...@@ -303,21 +314,22 @@ steps: ...@@ -303,21 +314,22 @@ steps:
- id: log - id: log
run: ../../lofar-cwl/steps/makesourcedb.cwl run: ../../lofar-cwl/steps/makesourcedb.cwl
label: make_sourcedb label: make_sourcedb
'sbg:x': 0 'sbg:x': 559.319091796875
'sbg:y': 500 'sbg:y': 723.5
- id: concat_logfiles_prep_cal - id: concat_logfiles_prep_cal
in: in:
- id: file_list - id: file_list
linkMerge: merge_flattened linkMerge: merge_flattened
source: ndppp_prep_cal/logfile source:
- ndppp_prep_cal/logfile
- id: file_prefix - id: file_prefix
default: ndppp_prep_cal default: ndppp_prep_cal
out: out:
- id: output - id: output
run: ../../steps/concatenate_files.cwl run: ../../steps/concatenate_files.cwl
label: concat_logfiles_prep_cal label: concat_logfiles_prep_cal
'sbg:x': 250 'sbg:x': 1027.490966796875
'sbg:y': 300 'sbg:y': 991
- id: concat_logfiles_blsmooth - id: concat_logfiles_blsmooth
in: in:
- id: file_list - id: file_list
...@@ -329,8 +341,8 @@ steps: ...@@ -329,8 +341,8 @@ steps:
- id: output - id: output
run: ../../steps/concatenate_files.cwl run: ../../steps/concatenate_files.cwl
label: concat_logfiles_blsmooth label: concat_logfiles_blsmooth
'sbg:x': 750 'sbg:x': 1329.937255859375
'sbg:y': 300 'sbg:y': 1105
- id: concat_logfiles_predict - id: concat_logfiles_predict
in: in:
- id: file_list - id: file_list
...@@ -343,8 +355,8 @@ steps: ...@@ -343,8 +355,8 @@ steps:
- id: output - id: output
run: ../../steps/concatenate_files.cwl run: ../../steps/concatenate_files.cwl
label: concat_logfiles_predict label: concat_logfiles_predict
'sbg:x': 750 'sbg:x': 1329.937255859375
'sbg:y': 500 'sbg:y': 891
- id: concat_logfiles_calib - id: concat_logfiles_calib
in: in:
- id: file_list - id: file_list
...@@ -356,8 +368,8 @@ steps: ...@@ -356,8 +368,8 @@ steps:
- id: output - id: output
run: ../../steps/concatenate_files.cwl run: ../../steps/concatenate_files.cwl
label: concat_logfiles_calib label: concat_logfiles_calib
'sbg:x': 750 'sbg:x': 1329.937255859375
'sbg:y': 800 'sbg:y': 998
- id: h5parm_collector - id: h5parm_collector
in: in:
- id: h5parmFiles - id: h5parmFiles
...@@ -374,8 +386,10 @@ steps: ...@@ -374,8 +386,10 @@ steps:
- id: log - id: log
run: ../../lofar-cwl/steps/H5ParmCollector.cwl run: ../../lofar-cwl/steps/H5ParmCollector.cwl
label: H5parm_collector label: H5parm_collector
'sbg:x': 750 'sbg:x': 1329.937255859375
'sbg:y': -300 'sbg:y': 777
requirements: requirements:
- class: SubworkflowFeatureRequirement - class: SubworkflowFeatureRequirement
- class: ScatterFeatureRequirement - class: ScatterFeatureRequirement
- class: InlineJavascriptRequirement
- class: StepInputExpressionRequirement
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment