Skip to content
Snippets Groups Projects
Commit ed8ccbd5 authored by Jörn Künsemöller's avatar Jörn Künsemöller
Browse files

TMSS-708: Support creating pulp dp SIPs

parent 9a13858e
Branches
Tags
4 merge requests!634WIP: COBALT commissioning delta,!512From master into TMSS-849-Commissioning-sprint-9,!508Resolve TMSS-708,!481Draft: SW-971 SW-973 SW-975: Various fixes to build LOFAR correctly.
...@@ -420,23 +420,22 @@ def create_sip_representation_for_dataproduct(dataproduct: Dataproduct): ...@@ -420,23 +420,22 @@ def create_sip_representation_for_dataproduct(dataproduct: Dataproduct):
elif dataproduct.dataformat.value == Dataformat.Choices.PULP_ANALYSIS.value: elif dataproduct.dataformat.value == Dataformat.Choices.PULP_ANALYSIS.value:
sip_dataproduct = siplib.PulpDataProduct( sip_dataproduct = siplib.PulpDataProduct(
dataproduct_map, dataproduct_map,
filecontent = ["content_a", "content_b"], filecontent = dataproduct.feedback_doc['files'],
datatype = "CoherentStokes", datatype = "CoherentStokes" if dataproduct.feedback_doc['target']['coherent'] else "IncoherentStokes", # todo: correct? what about complex voltages?
arraybeam = siplib.SimpleArrayBeam(siplib.ArrayBeamMap( arraybeam = siplib.SimpleArrayBeam(siplib.ArrayBeamMap(
subarraypointing_identifier = point_id, subarraypointing_identifier=get_siplib_identifier(dataproduct.sap.global_identifier, "SAP %s" % dataproduct.sap.id),
beamnumber = 4, beamnumber=dataproduct.specifications_doc['identifiers']['tab_index'] if 'identifiers' in dataproduct.specifications_doc else 0, # todo: verify
dispersionmeasure = 16, dispersionmeasure=0, # fixed
numberofsubbands = 3, numberofsubbands=len(dataproduct.feedback_doc['frequency']['subbands']),
stationsubbands = [1, 2, 3], stationsubbands=dataproduct.feedback_doc['frequency']['subbands'],
samplingtime = 3, samplingtime=dataproduct.feedback_doc['time']['sample_width'],
samplingtimeunit = "ms", samplingtimeunit="s",
centralfrequencies = "", centralfrequencies=dataproduct.feedback_doc['frequency']['central_frequencies'],
centralfrequencies_unit = "MHz", centralfrequencies_unit="Hz",
channelwidth_frequency = 160, channelwidth_frequency=dataproduct.feedback_doc['frequency']['channel_width'],
channelwidth_frequencyunit = "MHz", channelwidth_frequencyunit="Hz",
channelspersubband = 5, channelspersubband=dataproduct.feedback_doc['frequency']['channels_per_subband'],
stokes = ["I", "Q"] stokes=dataproduct.feedback_doc['samples']['polarisations']))
))
) )
# todo: distinguish and create other dataproduct types. Probably most of these can be filled in over time as needed, # todo: distinguish and create other dataproduct types. Probably most of these can be filled in over time as needed,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment