Skip to content
Snippets Groups Projects
Select Git revision
  • 940b45ac6798c2e2f0a7bbd43f69f9fb5513ca83
  • MCCS-163 default
  • main
  • sar-277-update-docs-with-examples-for-lrc
  • st-946-automate
  • sar_302-log-fix
  • sar-287_subarray_commands_to_lrc
  • sar_302-POC_await_sub_device_state
  • sat_302_fix_pipelines
  • sar-286_lrc_one_subarry_command
  • sar-286_lrc_improvements
  • sar-288-async-controller
  • sar-276-combine-tango-queue
  • sar-255_remove_nexus_reference
  • sar-275-add-LRC
  • sar-273-add-lrc-attributes
  • sar-272
  • sp-1106-marvin-1230525148-ska-tango-base
  • sp-1106-marvin-813091765-ska-tango-base
  • sar-255/Publish-package-to-CAR
  • mccs-661-device-under-test-fixture
  • mccs-659-pep257-docstring-linting
  • 0.11.3
  • 0.11.2
  • 0.11.1
  • 0.11.0
  • 0.10.1
  • 0.10.0
  • 0.9.1
  • 0.9.0
  • 0.8.1
  • 0.8.0
  • 0.7.2
  • 0.7.1
  • 0.7.0
  • 0.6.6
  • 0.6.5
  • 0.6.4
  • 0.6.3
  • 0.6.2
  • 0.6.1
  • 0.6.0
42 results

conf.py

Blame
  • Code owners
    Assign users and groups as approvers for specific file changes. Learn more.
    testset.py 8.98 KiB
    #TODO: fix test
    
    #""" test parameterset for resource estimator
    #"""
    
    #from lofar.sas.resourceassignment.resourceassignmentestimator.resource_estimators import ParameterSet
    
    #class TestSet(object):
        #def __init__(self):
            #self.check_set = ParameterSet()
            #self.valid_set = ParameterSet()
    
        #def clear(self):
            #self.check_set.clear()
            #self.valid_set.clear()
    
        #def test_dict(self):
            #return self.check_set.get_set()
    
        #def valid_dict(self):
            #return self.valid_set.get_set()
    
        ## for observation
        #def add_observation(self):
            #checkset = """
            #observation.sample_clock= 200
            #observation.duration=3600
            #observation.channels_per_subband= 61
            #observation.intergration_time= 1
            #observation.antenna_mode= HBA_DUAL
            #observation.stations= [CS001, CS002, RS307, RS509]
            #observation.flys_eye.enabled= false
            #observation.nr_beams= 0
    
            ## coherent_stokes.type can be: DATA_TYPE_XXYY or DATA_TYPE_STOKES_IQUV
            #observation.output.coherent_stokes.enabled= false
            #observation.output.coherent_stokes.type=
            #observation.output.coherent_stokes.integration_factor=
    
            ## incoherent_stokes.type can be: DATA_TYPE_STOKES_IQUV
            #observation.output.incoherent_stokes.enabled= false
            #observation.output.incoherent_stokes.type=
    
            ## for calibration-pipeline
            #dp.output.correlated.enabled= false
            #dp.output.correlated.demixing_settings.freq_step=
            #dp.output.correlated.demixing_settings.time_step=
            #dp.output.instrument_model.enabled= false
    
            ## for longbaseline-pipeline
            #dp.output.longbaseline.enabled= false
            #dp.output.longbaseline.subband_groups_per_ms=
            #dp.output.longbaseline.subbands_per_subband_group=
    
            ## for pulsar-pipeline
            #dp.output.pulsar.enabled= false
    
            ## for image-pipeline
            #dp.output.skyimage.enabled= false
            #dp.output.skyimage.slices_per_image=
            #dp.output.skyimage.subbands_per_image=
            #"""
            #self.check_set.import_string(checkset)
            #validset = """
            #observation.total_data_size=
            #observation.total_bandwidth=
            #observation.output_files.dp_correlated_uv.nr_files=
            #observation.output_files.dp_correlated_uv.file_size=
            #observation.output_files.dp_coherent_stokes.nr_files=
            #observation.output_files.dp_coherent_stokes.file_size=
            #observation.output_files.dp_incoherent_stokes.nr_files=
            #observation.output_files.dp_incoherent_stokes.file_size=
            #"""
            #self.valid_set.import_string(validset)
    
    
        #def add_observation_beams(self):
            #checkset = """
            #observation.nr_beams= 2
            #observation.beam[0].nr_subbands= 400
            #observation.beam[0].nr_tab_rings= 4
            #observation.beam[0].tied_array_beam[0].coherent= true
            #observation.beam[0].tied_array_beam[1].coherent= true
            #observation.beam[1].nr_subbands= 400
            #observation.beam[1].nr_tab_rings= 4
            #observation.beam[1].tied_array_beam[0].coherent= true
            #observation.beam[1].tied_array_beam[1].coherent= true
            #"""
            #self.check_set.import_string(checkset)
            #self.check_set.import_string(checkset)
            #validset = """
            #observation.total_data_size=
            #observation.total_bandwidth=
            #observation.output_files.dp_correlated_uv.nr_files=
            #observation.output_files.dp_correlated_uv.file_size=
            #observation.output_files.dp_coherent_stokes.nr_files=
            #observation.output_files.dp_coherent_stokes.file_size=
            #observation.output_files.dp_incoherent_stokes.nr_files=
            #observation.output_files.dp_incoherent_stokes.file_size=
            #"""
            #self.valid_set.import_string(validset)
    
    
        #def enable_observations_coherent_stokes(self):
            #checkset = """
            ## coherent_stokes.type can be: DATA_TYPE_XXYY or DATA_TYPE_STOKES_IQUV
            #observation.output.coherent_stokes.enabled= true
            #observation.output.coherent_stokes.type= DATA_TYPE_XXYY
            #observation.output.coherent_stokes.integration_factor= 1
            #"""
            #self.check_set.import_string(checkset)
            #self.check_set.import_string(checkset)
            #validset = """
            #observation.total_data_size=
            #observation.total_bandwidth=
            #observation.output_files.dp_correlated_uv.nr_files=
            #observation.output_files.dp_correlated_uv.file_size=
            #observation.output_files.dp_coherent_stokes.nr_files=
            #observation.output_files.dp_coherent_stokes.file_size=
            #observation.output_files.dp_incoherent_stokes.nr_files=
            #observation.output_files.dp_incoherent_stokes.file_size=
            #"""
            #self.valid_set.import_string(validset)
    
    
        #def enable_observations_incoherent_stokes(self):
            #checkset = """
            ## incoherent_stokes.type can be: DATA_TYPE_STOKES_IQUV
            #observation.output.incoherent_stokes.enabled= true
            #observation.output.incoherent_stokes.type= DATA_TYPE_STOKES_IQUV
            #"""
            #self.check_set.import_string(checkset)
            #self.check_set.import_string(checkset)
            #validset = """
            #observation.total_data_size=
            #observation.total_bandwidth=
            #observation.output_files.dp_correlated_uv.nr_files=
            #observation.output_files.dp_correlated_uv.file_size=
            #observation.output_files.dp_coherent_stokes.nr_files=
            #observation.output_files.dp_coherent_stokes.file_size=
            #observation.output_files.dp_incoherent_stokes.nr_files=
            #observation.output_files.dp_incoherent_stokes.file_size=
            #"""
            #self.valid_set.import_string(validset)
    
    
        #def enabble_flys_eye(self):
            #checkset = """
            #observation.flys_eye.enabled= true
            #"""
            #self.check_set.import_string(checkset)
            #self.check_set.import_string(checkset)
            #validset = """
            #observation.total_data_size=
            #observation.total_bandwidth=
            #observation.output_files.dp_correlated_uv.nr_files=
            #observation.output_files.dp_correlated_uv.file_size=
            #observation.output_files.dp_coherent_stokes.nr_files=
            #observation.output_files.dp_coherent_stokes.file_size=
            #observation.output_files.dp_incoherent_stokes.nr_files=
            #observation.output_files.dp_incoherent_stokes.file_size=
            #"""
            #self.valid_set.import_string(validset)
    
        ## for all pipelines
        #def enable_calibration_pipeline(self):
            #checkset = """
            ## for calibration-pipeline
            #dp.output.correlated.enabled= true
            #dp.output.correlated.demixing_settings.freq_step= 60
            #dp.output.correlated.demixing_settings.time_step= 10
            #dp.output.instrument_model.enabled= true
            #"""
            #self.check_set.import_string(checkset)
            #self.check_set.import_string(checkset)
            #validset = """
            #calibration_pipeline.total_data_size=
            #calibration_pipeline.total_bandwidth=
            #calibration_pipeline.dp_correlated_uv.nr_files=
            #calibration_pipeline.dp_correlated_uv.file_size=
            #calibration_pipeline.dp_instrument_model.nr_files=
            #calibration_pipeline.dp_instrument_model.file_size=
            #"""
            #self.valid_set.import_string(validset)
    
    
        #def enable_longbaseline_pipeline(self):
            #checkset = """
            ## for -pipeline
            #dp.output.longbaseline.enabled= true
            #dp.output.longbaseline.subband_groups_per_ms= 1
            #dp.output.longbaseline.subbands_per_subband_group= 1
            #"""
            #self.check_set.import_string(checkset)
            #self.check_set.import_string(checkset)
            #validset = """
            #longbaseline_pipeline.total_data_size=
            #longbaseline_pipeline.total_bandwidth=
            #longbaseline_pipeline.dp_correlated_uv.nr_files=
            #longbaseline_pipeline.dp_correlated_uv.file_size=
            #"""
            #self.valid_set.import_string(validset)
    
    
        #def enable_pulsar_pipeline(self):
            #checkset = """
            ## for pulsar-pipeline
            #dp.output.pulsar.enabled= true
            #"""
            #self.check_set.import_string(checkset)
            #self.check_set.import_string(checkset)
            #validset = """
            #pulsar_pipeline.total_data_size=
            #pulsar_pipeline.total_bandwidth=
            #pulsar_pipeline.dp_pulsar.nr_files=
            #pulsar_pipeline.dp_pulsar.file_size=
            #"""
            #self.valid_set.import_string(validset)
    
    
        #def enable_image_pipeline(self):
            #checkset = """
            ## for image-pipeline
            #dp.output.skyimage.enabled= true
            #dp.output.skyimage.slices_per_image= 1
            #dp.output.skyimage.subbands_per_image= 2
            #"""
            #self.check_set.import_string(checkset)
            #self.check_set.import_string(checkset)
            #validset = """
            #image_pipeline.total_data_size=
            #image_pipeline.total_bandwidth=
            #image_pipeline.dp_sky_image.nr_files=
            #image_pipeline.dp_sky_image.file_size=
            #"""
            #self.valid_set.import_string(validset)