Add substream to metadata

src/AsapoWorker/asapo_receiver.py

@@ -83,6 +83,8 @@ class SimpleAsapoReceiver:
         current_id = metadata["_id"]
         log.info("Received record with id=%i.", current_id)
 
+        metadata["substream"] = self.substream
+
         return data, metadata
 
     def get_current_size(self):
@@ -182,6 +184,9 @@ class SerialAsapoReceiver(SimpleAsapoReceiver):
 
         self.expected_id = current_id + 1
         self.retries = 0
+
+        metadata["substream"] = self.substream
+
         return data, metadata
 
     def _set_marker(self):
@@ -258,4 +263,6 @@ class SerialAsapoReceiver(SimpleAsapoReceiver):
         # ASAP::O sets the last read marker when calling get_last
         self.need_set_marker = True
 
+        metadata["substream"] = self.substream
+
         return data, metadata