adjust outgoing WNM data_id

ECCC-MSC · Jan 29, 2024 · 861e737 · 861e737
1 parent 7db535c
commit 861e737
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/msc_wis2node/publisher.py b/msc_wis2node/publisher.py
@@ -168,6 +168,11 @@ def publish_to_wis2(self, dataset: str, url: str) -> None:
             url=url
         )
 
+        LOGGER.debug('Removing system and version from data_id')
+        data_id = message['properties']['data_id']
+        tokens = data_id.split('/')
+        message['properties']['data_id'] = '/'.join(tokens[2:])
+
         LOGGER.debug(json.dumps(message, indent=4))
         LOGGER.info('Publishing WIS2 notification message')