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

TMSS-573: fixed feedback handling for the weird old and almost obsolete qpid messages

parent 5f6dea60
No related branches found
No related tags found
1 merge request!343Resolve TMSS-557 and TMSS-307
...@@ -76,16 +76,19 @@ class TMSSFeedbackListener: ...@@ -76,16 +76,19 @@ class TMSSFeedbackListener:
msg = fbus.get(1) msg = fbus.get(1)
if msg is not None: if msg is not None:
content = msg.content()
logger.info("received feedback from bus='%s' %s", ex, tmss_subtask_id, content)
# note: cobalt/rtcp creates feedback and assumes that the observationID has its origin in OTDB. # note: cobalt/rtcp creates feedback and assumes that the observationID has its origin in OTDB.
# hence, it stores this id in the 'sasid' property of the message. # hence, it stores this id in the 'sasid' property of the message.
# We know that TMSS sets its subtask_id in the parset in the Observation.ObsID field, # We know that TMSS sets its subtask_id in the parset in the Observation.ObsID field,
# so we can fetch the TMSS subtask_id from the msg's sasid. # so we can fetch the TMSS subtask_id from the msg's sasid.
tmss_subtask_id = msg.sasid tmss_subtask_id = content.sasid
logger.info("received feedback from bus='%s' for TMSS subtask id=%s payload=%s", ex, tmss_subtask_id, msg.payload) logger.info("feedback for TMSS subtask id=%s payload=%s", ex, tmss_subtask_id, content.payload)
# add contained feedback to TMSS # add contained feedback to TMSS
self.append_feedback_to_tmss_subtask_raw_feedback(tmss_subtask_id, msg.payload) self.append_feedback_to_tmss_subtask_raw_feedback(tmss_subtask_id, content.payload)
# try processing it, which will will fail until feedback of the subtask is complete. # try processing it, which will will fail until feedback of the subtask is complete.
self.process_subtask_feedback_and_set_finished(tmss_subtask_id) self.process_subtask_feedback_and_set_finished(tmss_subtask_id)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment