diff --git a/SAS/ResourceAssignment/ResourceAssignmentEstimator/resource_estimators/longbaseline_pipeline.py b/SAS/ResourceAssignment/ResourceAssignmentEstimator/resource_estimators/longbaseline_pipeline.py index 07779a61e5cea217d4564032cae8b306d53d7823..2a6678c0f5a9822122c3c97c447db095e76abb02 100644 --- a/SAS/ResourceAssignment/ResourceAssignmentEstimator/resource_estimators/longbaseline_pipeline.py +++ b/SAS/ResourceAssignment/ResourceAssignmentEstimator/resource_estimators/longbaseline_pipeline.py @@ -91,9 +91,9 @@ class LongBaselinePipelineResourceEstimator(BaseResourceEstimator): result['storage']['output_files'] = {} nr_output_files = nr_input_files / (subbands_per_subbandgroup * subbandgroups_per_ms) result['storage']['output_files']['uv'] = {'nr_of_uv_files': nr_output_files, - 'uv_file_size': 1000, + 'uv_file_size': 1000, # 1 kB was hardcoded in the Scheduler 'identifications': parset.getStringVector(DATAPRODUCTS + 'Output_Correlated.identifications'), - 'start_sb_nr': input_files['uv']['start_sb_nr']} # 1 kB was hardcoded in the Scheduler + 'start_sbg_nr': input_files['uv']['start_sb_nr'] / (subbands_per_subbandgroup * subbandgroups_per_ms)} logger.debug("correlated_uv: {} files {} bytes each".format(result['storage']['output_files']['uv']['nr_of_uv_files'], result['storage']['output_files']['uv']['uv_file_size'])) # count total data size