diff --git a/SAS/TMSS/backend/services/feedback_handling/lib/feedback_handling.py b/SAS/TMSS/backend/services/feedback_handling/lib/feedback_handling.py index 4c9658a05cd9df7b158b5464d017bf75a90e3e2d..346eb082a1a9de4c291bd997a7e4c6f482a8e8cc 100644 --- a/SAS/TMSS/backend/services/feedback_handling/lib/feedback_handling.py +++ b/SAS/TMSS/backend/services/feedback_handling/lib/feedback_handling.py @@ -76,16 +76,19 @@ class TMSSFeedbackListener: msg = fbus.get(1) 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. # 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, # 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 - 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. self.process_subtask_feedback_and_set_finished(tmss_subtask_id)