Newer
Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
class: Workflow
cwlVersion: v1.0
id: finalize
label: finalize
$namespaces:
sbg: 'https://www.sevenbridges.com/'
inputs:
- id: msin
type: 'Directory[]'
'sbg:x': -1000
'sbg:y': -400
- id: input_h5parm
type: File
'sbg:x': -1000
'sbg:y': -300
- id: inh5parm_logfile
type: 'File[]'
'sbg:x': -1000
'sbg:y': -200
- id: gsmcal_step
type: string
'sbg:x': -1000
'sbg:y': -200
- id: process_baselines_target
type: string
'sbg:x': -1000
'sbg:y': -100
- id: bad_antennas
type: string
'sbg:x': -1000
'sbg:y': 0
- id: insolutions
type: File
'sbg:x': -1000
'sbg:y': 100
- id: compression_bitrate
type: int
'sbg:x': -1000
'sbg:y': 200
outputs:
- id: msout
outputSource:
- apply_gsmcal/msout
type: 'Directory[]'
'sbg:x': 1000
'sbg:y': 0
- id: solutions
outputSource:
- write_solutions/outh5parm
type: File
'sbg:x': 1000
'sbg:y': 200
- id: logfiles
outputSource:
- concat_logfiles_applygsm/output
- concat_logfiles_solutions/output
type: 'File[]'
linkMerge: merge_flattened
'sbg:x': 1000
'sbg:y': 800
steps:
- id: add_missing_stations
in:
- id: h5parm
source: input_h5parm
- id: solset
default: 'sol000'
- id: refsolset
default: 'target'
- id: refh5parm
source: insolutions
- id: soltab_in
source: gsmcal_step
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
- id: soltab_out
default: 'TGSSphase'
- id: filter
source: process_baselines_target
- id: bad_antennas
source: bad_antennas
out:
- id: outh5parm
- id: log
run: ../../steps/add_missing_stations.cwl
label: add_missing_stations
'sbg:x': -200
'sbg:y': -300
- id: apply_gsmcal
in:
- id: msin
source: msin
- id: msin_datacolumn
default: DATA
- id: parmdb
source: write_solutions/outh5parm
- id: msout_datacolumn
default: DATA
- id: storagemanager
default: Dysco
- id: databitrate
source: compression_bitrate
- id: correction
default: 'TGSSphase'
- id: solset
default: 'target'
- id: msout_name
source: msin
valueFrom: $(self.basename+'_prep.ms')
out:
- id: msout
- id: logfile
run: ../../lofar-cwl/steps/applytarget.cwl
label: apply_gsmcal
scatter:
- msin
'sbg:x': 400
'sbg:y': 0
- id: write_solutions
in:
- id: h5parmFile
source: add_missing_stations/outh5parm
- id: outsolset
default: target
- id: insoltab
default: 'TGSSphase'
- id: input_file
source: insolutions
- id: squeeze
default: true
- id: verbose
default: true
- id: history
default: true
out:
- id: outh5parm
- id: log
run: ../../steps/h5parmcat.cwl
label: write_solutions
'sbg:x': 200
'sbg:y': 500
- id: concat_logfiles_applygsm
in:
- id: file_list
source:
- apply_gsmcal/logfile
- id: file_prefix
default: apply_gsmcal
out:
- id: output
run: ../../steps/concatenate_files.cwl
label: concat_logfiles_applygsm
'sbg:x': 750
'sbg:y': 500
- id: concat_logfiles_solutions
in:
- id: file_list
linkMerge: merge_flattened
source:
- inh5parm_logfile
- add_missing_stations/log
- write_solutions/log
- id: file_prefix
default: losoto_gsmcal
out:
- id: output
run: ../../steps/concatenate_files.cwl
label: concat_logfiles_solutions
'sbg:x': 500
'sbg:y': 500
requirements:
- class: SubworkflowFeatureRequirement
- class: ScatterFeatureRequirement
- class: StepInputExpressionRequirement
- class: InlineJavascriptRequirement