diff --git a/SAS/ResourceAssignment/ResourceAssignmentEstimator/service.py b/SAS/ResourceAssignment/ResourceAssignmentEstimator/service.py index 0c69d9b8a2a40404309181ee8722251008eb2df8..55cb19d86e5a8c6a01280c1da45e3d64c6c9596c 100644 --- a/SAS/ResourceAssignment/ResourceAssignmentEstimator/service.py +++ b/SAS/ResourceAssignment/ResourceAssignmentEstimator/service.py @@ -54,7 +54,8 @@ class ResourceEstimatorHandler(MessageHandlerInterface): if not 'im' in estimate.values()[0]['storage']['output_files'] and 'uv' in estimate.values()[0]['storage']['output_files']: # Not a calibrator pipeline logger.info('found %s as the target of pipeline %s' % (id, otdb_id)) input_files['uv'] = estimate.values()[0]['storage']['output_files']['uv'] - input_files['saps'] = estimate.values()[0]['storage']['output_files']['saps'] + if 'saps' in estimate.values()[0]['storage']['output_files']: + input_files['saps'] = estimate.values()[0]['storage']['output_files']['saps'] elif 'im' in estimate.values()[0]['storage']['output_files']: input_files['im'] = estimate.values()[0]['storage']['output_files']['im'] return {str(otdb_id): self.add_id(self.calibration_pipeline.verify_and_estimate(parset, input_files), otdb_id)}