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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
class: CommandLineTool
cwlVersion: v1.1
id: make_parset
label: define_parset
$namespaces:
sbg: 'https://www.sevenbridges.com/'
inputs:
- id: raw_data
type: boolean?
default: false
- id: demix
type: boolean?
default: false
- id: apply_tec_correction
type: boolean?
default: false
- id: apply_rm_correction
type: boolean?
default: true
- id: apply_phase_correction
type: boolean?
default: false
- id: apply_clock_correction
type: boolean?
default: true
- id: apply_beam_correction
type: boolean?
default: true
- id: filter_baselines
type: string?
default: '[CR]S*&'
- id: memoryperc
type: int?
default: 20
- id: baselines_to_flag
type: 'string[]?'
default: []
- id: elevation_to_flag
type: string?
default: '0deg..15deg'
- id: min_amplitude_to_flag
type: float?
default: 1e-30
- id: updateweights
type: boolean?
default: true
- id: timeresolution
type: int?
default: 4
- id: freqresolution
type: string?
default: '48.82kHz'
- id: process_baselines_target
type: string?
default: '[CR]S*&'
- id: demix_timestep
type: int?
default: 10
- id: demix_freqstep
type: int?
default: 16
- id: target_source
type: string?
default: ''
- id: subtract_sources
type: 'string[]?'
default:
- CasA
- CygA
- id: ntimechunk
type: int?
default: 10
outputs:
- id: output
type: File
outputBinding:
glob: DPPP.parset
baseCommand:
- cp
arguments:
- prefix: ''
shellQuote: false
position: 0
valueFrom: input.parset
- prefix: ''
shellQuote: false
position: 0
valueFrom: DPPP.parset
requirements:
- class: InlineJavascriptRequirement
- class: ShellCommandRequirement
- class: InitialWorkDirRequirement
listing:
- entryname: input.parset
entry: |+
steps = [count1,$(inputs.raw_data?'flagedge,aoflag,':'')flagbaseline,flagelev,flagamp,$(inputs.demix?'demix,':'')filter,applyPA,applybandpass,$(inputs.apply_clock_correction?'applyclock,':'')$(inputs.apply_beam_correction?'applybeam,':'')$(inputs.apply_rm_correction?'applyRM,':'')$(inputs.apply_tec_correction?'applytec,':'')$(inputs.apply_phase_correction?'applyphase,':'')avg,count2]
#
msout.storagemanager = "Dysco"
msout.storagemanager.databitrate = 0
#
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
filter.type = filter
filter.baseline = $(inputs.filter_baselines)
filter.remove = true
#
flagedge.type = preflagger
flagedge.chan = [0..nchan/32-1,31*nchan/32..nchan-1]
#
aoflag.type = aoflagger
aoflag.memoryperc = $(inputs.memoryperc)
aoflag.keepstatistics = false
#
flagbaseline.type = preflagger
flagbaseline.baseline = $(inputs.baselines_to_flag)
#
flagelev.type = preflagger
flagelev.elevation = $(inputs.elevation_to_flag)
#
flagamp.type = preflagger
flagamp.amplmin = $(inputs.min_amplitude_to_flag)
#
applyPA.type = applycal
applyPA.correction = polalign
applyPA.solset = calibrator
#
applybandpass.type = applycal
applybandpass.correction = bandpass
applybandpass.updateweights = $(inputs.updateweights?'True':'False')
applybandpass.solset = calibrator
#
applyclock.type = applycal
applyclock.correction = clock
applyclock.solset = calibrator
#
applytec.type = applycal
applytec.correction = tec
applytec.solset = calibrator
#
applyphase.type = applycal
applyphase.correction = phaseOrig
applyphase.solset = calibrator
#
applyRM.type = applycal
applyRM.correction = RMextract
applyRM.solset = target
#
applybeam.type = applybeam
applybeam.usechannelfreq = True
applybeam.updateweights = $(inputs.updateweights?'True':'False')
applybeam.invert = True
applybeam.beammode = element
#
avg.type = average
avg.timeresolution = $(inputs.timeresolution)
avg.freqresolution = $(inputs.freqresolution)
#
demix.type = demixer
demix.baseline = $(inputs.process_baselines_target)
demix.demixfreqstep = $(inputs.demix_freqstep)
demix.demixtimestep = $(inputs.demix_timestep)
demix.ignoretarget = False
demix.targetsource = $(inputs.target_source)
demix.subtractsources = $(inputs.subtract_sources)
demix.ntimechunk = $(inputs.ntimechunk)
demix.freqstep = 1
demix.timestep = 1
demix.instrumentmodel = instrument