diff --git a/singer_sdk/target_base.py b/singer_sdk/target_base.py index d560a555e..8ecdfa851 100644 --- 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.