diff --git a/SAS/TMSS/backend/services/postgres_listener/lib/postgres_listener.py b/SAS/TMSS/backend/services/postgres_listener/lib/postgres_listener.py index 9707e813635abebb19bfb2b349e2505c2a706146..218449c67d6343b722bdc7b0a25ce8df756d0f80 100644 --- a/SAS/TMSS/backend/services/postgres_listener/lib/postgres_listener.py +++ b/SAS/TMSS/backend/services/postgres_listener/lib/postgres_listener.py @@ -349,8 +349,11 @@ class TMSSPGListener(PostgresListener): {'name': project_name, 'status': project_status}) def onProjectRankUpdated(self, payload = None): - self._sendNotification(TMSS_PROJECT_OBJECT_EVENT_PREFIX+'.Rank.Updated', payload) - + payload_dict = json.loads(payload) + name = payload_dict['name'] + rank = payload_dict['new']['rank'] + self._sendNotification(TMSS_PROJECT_OBJECT_EVENT_PREFIX+'.Rank.Updated', + {'name': name, 'rank': rank}) def onProjectQuotaArchiveLocationInserted(self, payload = None): self._sendNotification(TMSS_PROJECTQUOTAARCHIVELOCATION_OBJECT_EVENT_PREFIX+'.Created', payload)