@@ -155,14 +155,13 @@ def _construct_doc(self):
155
155
156
156
# Status XML
157
157
# return the correct response depending on the progress of the process
158
- if self .status > = STATUS .STORE_AND_UPDATE_STATUS :
158
+ if self .status = = STATUS .STORE_AND_UPDATE_STATUS :
159
159
if self .status_percentage == 0 :
160
160
self .message = 'PyWPS Process %s accepted' % self .process .identifier
161
161
status_doc = self ._process_accepted ()
162
162
doc .append (status_doc )
163
- #self.write_response_doc(doc)
164
163
return doc
165
- elif 0 < self .status_percentage < 100 :
164
+ elif self .status_percentage > 0 :
166
165
status_doc = self ._process_started ()
167
166
doc .append (status_doc )
168
167
return doc
@@ -175,20 +174,21 @@ def _construct_doc(self):
175
174
176
175
# TODO: add paused status
177
176
178
- status_doc = self ._process_succeeded ()
179
- doc .append (status_doc )
177
+ if self .status == STATUS .DONE_STATUS :
178
+ status_doc = self ._process_succeeded ()
179
+ doc .append (status_doc )
180
180
181
- # DataInputs and DataOutputs definition XML if lineage=true
182
- if self .wps_request .lineage == 'true' :
183
- data_inputs = [self .wps_request .inputs [i ][0 ].execute_xml () for i in self .wps_request .inputs ]
184
- doc .append (WPS .DataInputs (* data_inputs ))
181
+ # DataInputs and DataOutputs definition XML if lineage=true
182
+ if self .wps_request .lineage == 'true' :
183
+ data_inputs = [self .wps_request .inputs [i ][0 ].execute_xml () for i in self .wps_request .inputs ]
184
+ doc .append (WPS .DataInputs (* data_inputs ))
185
185
186
- output_definitions = [self .outputs [o ].execute_xml_lineage () for o in self .outputs ]
187
- doc .append (WPS .OutputDefinitions (* output_definitions ))
186
+ output_definitions = [self .outputs [o ].execute_xml_lineage () for o in self .outputs ]
187
+ doc .append (WPS .OutputDefinitions (* output_definitions ))
188
188
189
- # Process outputs XML
190
- output_elements = [self .outputs [o ].execute_xml () for o in self .outputs ]
191
- doc .append (WPS .ProcessOutputs (* output_elements ))
189
+ # Process outputs XML
190
+ output_elements = [self .outputs [o ].execute_xml () for o in self .outputs ]
191
+ doc .append (WPS .ProcessOutputs (* output_elements ))
192
192
return doc
193
193
194
194
def call_on_close (self , function ):
0 commit comments