Skip to content
Snippets Groups Projects
Commit b343e4e6 authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

Task #8887: added momId to parset subset

parent 23acd48d
No related branches found
No related tags found
No related merge requests found
...@@ -82,6 +82,7 @@ def resourceIndicatorsFromParset( parset ): ...@@ -82,6 +82,7 @@ def resourceIndicatorsFromParset( parset ):
# ===================================== # =====================================
# Observation settings # Observation settings
# ===================================== # =====================================
add("Observation.momID")
add("Observation.sampleClock") add("Observation.sampleClock")
add("Observation.nrBitsPerSample") add("Observation.nrBitsPerSample")
add("Observation.antennaSet") add("Observation.antennaSet")
...@@ -179,6 +180,7 @@ class RATaskSpecified(OTDBBusListener): ...@@ -179,6 +180,7 @@ class RATaskSpecified(OTDBBusListener):
# Request the parset # Request the parset
main_obsID = treeId main_obsID = treeId
main_parset,_ = self.parset_rpc( OtdbID=main_obsID ) main_parset,_ = self.parset_rpc( OtdbID=main_obsID )
logger.info("main_parset [%s]: %s" % (main_obsID, main_parset))
# Construct a dict of all the parsets we retrieved # Construct a dict of all the parsets we retrieved
parsets = {} parsets = {}
...@@ -203,6 +205,7 @@ class RATaskSpecified(OTDBBusListener): ...@@ -203,6 +205,7 @@ class RATaskSpecified(OTDBBusListener):
# Request predecessor parset # Request predecessor parset
parsets[obsID],_ = self.parset_rpc( OtdbID=obsID ) parsets[obsID],_ = self.parset_rpc( OtdbID=obsID )
logger.info("predecessor parset [%s]: %s" % (obsID, parsets[obsID]))
# Add the list of predecessors # Add the list of predecessors
request_obsIDs = request_obsIDs.union(predecessors(parsets[obsID])) request_obsIDs = request_obsIDs.union(predecessors(parsets[obsID]))
......
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