Ensure support at target

meltano · Sep 13, 2024 · a43e93f · a43e93f
1 parent 547a801
commit a43e93f
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/singer_sdk/target_base.py b/singer_sdk/target_base.py
@@ -462,7 +462,10 @@ def _process_batch_message(self, message_dict: dict) -> None:
         Args:
             message_dict: TODO
         """
-        sink = self.get_sink(message_dict["stream"])
+        stream_name = message_dict["stream"]
+
+        for stream_map in self.mapper.stream_maps[stream_name]:
+            sink = self.get_sink(stream_map.stream_alias)
 
         encoding = BaseBatchFileEncoding.from_dict(message_dict["encoding"])
         sink.process_batch_files(