1#!/usr/bin/env cwl-runner
2### Test harness for aqs.cwl
3
4cwlVersion: v1.2
5class: Workflow
6
7requirements:
8 InlineJavascriptRequirement: {}
9 ScatterFeatureRequirement: {}
10 StepInputExpressionRequirement: {}
11 SubworkflowFeatureRequirement: {}
12
13
14# All inputs of original pipeline, remove what is not needed
15inputs:
16 aggregation:
17 type: string
18 connection_name:
19 doc: The name of the section in the database.ini file
20 type: string
21 database:
22 doc: Path to database connection file, usually database.ini
23 type: File
24 parameter_code:
25 doc: 'Parameter code. Either a numeric code (e.g. 88101, 44201)
26
27 or symbolic name (e.g. PM25, NO2).
28
29 See more: [AQS Code List](https://www.epa.gov/aqs/aqs-code-list)
30
31 '
32 type: string
33 proxy:
34 default: ''
35 doc: HTTP/HTTPS Proxy if required
36 type: string?
37 table:
38 doc: Name of the table to be created in the database
39 type: string
40 test_script:
41 doc: File containing SQL test script
42 type:
43 - File[]
44 years:
45 doc: Years to download
46 type: string[]
47
48
49steps:
50 execute:
51 run: aqs.cwl
52 in:
53 proxy: proxy
54 database: database
55 connection_name: connection_name
56 aggregation: aggregation
57 parameter_code: parameter_code
58 table: table
59 years: years
60 out:
61 - initdb_log
62 - expand_log
63 - introspect_log
64 - ingest_log
65 - index_log
66 - vacuum_log
67 - data
68 - model
69 - introspect_err
70 - ingest_err
71 - index_err
72 - vacuum_err
73
74 verify:
75 run: run_test.cwl
76 in:
77 database: database
78 connection_name: connection_name
79 script: test_script
80 depends_on: execute/vacuum_err
81 out:
82 - log
83 - errors
84
85outputs:
86## Generated by nsaph/util/cwl_collect_outputs.py from aqs.cwl:
87 execute_initdb_log:
88 type: File
89 outputSource: execute/initdb_log
90 execute_expand_log:
91 type: File
92 outputSource: execute/expand_log
93 execute_introspect_log:
94 type: File
95 outputSource: execute/introspect_log
96 execute_ingest_log:
97 type: File
98 outputSource: execute/ingest_log
99 execute_index_log:
100 type: File
101 outputSource: execute/index_log
102 execute_vacuum_log:
103 type: File
104 outputSource: execute/vacuum_log
105 execute_data:
106 type: File
107 outputSource: execute/data
108 execute_model:
109 type: File
110 outputSource: execute/model
111 execute_introspect_err:
112 type: File
113 outputSource: execute/introspect_err
114 execute_ingest_err:
115 type: File
116 outputSource: execute/ingest_err
117 execute_index_err:
118 type: File
119 outputSource: execute/index_err
120 execute_vacuum_err:
121 type: File
122 outputSource: execute/vacuum_err
123## Generated by nsaph/util/cwl_collect_outputs.py from run_test.cwl:
124 verify_log:
125 type: File
126 outputSource: verify/log
127 verify_errors:
128 type: File
129 outputSource: verify/errors