fix: Use mapped stream aliases when handling ACTIVATE_VERSION messa…

…ges in the base target class Closes #1055
meltano · Jul 19, 2024 · 5db0c23 · 5db0c23
1 parent 119a5ec
commit 5db0c23
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/singer_sdk/target_base.py b/singer_sdk/target_base.py
@@ -451,8 +451,10 @@ def _process_activate_version_message(self, message_dict: dict) -> None:
             message_dict: TODO
         """
         stream_name = message_dict["stream"]
-        sink = self.get_sink(stream_name)
-        sink.activate_version(message_dict["version"])
+
+        for stream_map in self.mapper.stream_maps[stream_name]:
+            sink = self.get_sink(stream_map.stream_alias)
+            sink.activate_version(message_dict["version"])
 
     def _process_batch_message(self, message_dict: dict) -> None:
         """Handle the optional BATCH message extension.