Skip to content
Snippets Groups Projects
Commit b2527ff5 authored by Adriaan Renting's avatar Adriaan Renting
Browse files

Task #9640: SB should be SBG in output filenames of LB pipeline

parent 0aa4cd10
No related branches found
No related tags found
No related merge requests found
...@@ -91,9 +91,9 @@ class LongBaselinePipelineResourceEstimator(BaseResourceEstimator): ...@@ -91,9 +91,9 @@ class LongBaselinePipelineResourceEstimator(BaseResourceEstimator):
result['storage']['output_files'] = {} result['storage']['output_files'] = {}
nr_output_files = nr_input_files / (subbands_per_subbandgroup * subbandgroups_per_ms) nr_output_files = nr_input_files / (subbands_per_subbandgroup * subbandgroups_per_ms)
result['storage']['output_files']['uv'] = {'nr_of_uv_files': nr_output_files, 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'), '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'])) 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 # count total data size
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment