diff --git a/wis2box-management/wis2box/data/bufr4.py b/wis2box-management/wis2box/data/bufr4.py
index 82fed6c3..6fccf18a 100644
--- a/wis2box-management/wis2box/data/bufr4.py
+++ b/wis2box-management/wis2box/data/bufr4.py
@@ -54,6 +54,7 @@ def transform(self, input_data: Union[Path, bytes],
         payload = {
             'inputs': {
                 'channel': self.topic_hierarchy.replace('origin/a/wis2/', ''),
+                'metadata_id': self.metadata_id,
                 'notify': False,
                 'data': data
             }
diff --git a/wis2box-management/wis2box/data/csv2bufr.py b/wis2box-management/wis2box/data/csv2bufr.py
index 767a8a2c..d0d617f7 100644
--- a/wis2box-management/wis2box/data/csv2bufr.py
+++ b/wis2box-management/wis2box/data/csv2bufr.py
@@ -66,6 +66,7 @@ def transform(self, input_data: Union[Path, bytes],
         payload = {
             'inputs': {
                 'channel': self.topic_hierarchy.replace('origin/a/wis2/', ''),
+                'metadata_id': self.metadata_id,
                 'template': self.template,
                 'notify': False,
                 'data': data
diff --git a/wis2box-management/wis2box/data/synop2bufr.py b/wis2box-management/wis2box/data/synop2bufr.py
index 78e00aeb..9a5f1632 100644
--- a/wis2box-management/wis2box/data/synop2bufr.py
+++ b/wis2box-management/wis2box/data/synop2bufr.py
@@ -76,6 +76,7 @@ def transform(self, input_data: Union[Path, bytes],
         payload = {
             'inputs': {
                 'channel': self.topic_hierarchy.replace('origin/a/wis2/', ''),
+                'metadata_id': self.metadata_id,
                 'year': year,
                 'month': month,
                 'notify': False,