@@ -752,7 +752,7 @@ def _init_mappings(self) -> None:
752752 OAuthAuthenticatorModel : self .create_oauth_authenticator ,
753753 OffsetIncrementModel : self .create_offset_increment ,
754754 PageIncrementModel : self .create_page_increment ,
755- ParentStreamConfigModel : self ._create_message_repository_substream_wrapper ,
755+ ParentStreamConfigModel : self .create_parent_stream_config_with_substream_wrapper ,
756756 PredicateValidatorModel : self .create_predicate_validator ,
757757 PropertiesFromEndpointModel : self .create_properties_from_endpoint ,
758758 PropertyChunkingModel : self .create_property_chunking ,
@@ -3688,7 +3688,7 @@ def create_substream_partition_router(
36883688 if model .parent_stream_configs :
36893689 parent_stream_configs .extend (
36903690 [
3691- self ._create_message_repository_substream_wrapper (
3691+ self .create_parent_stream_config_with_substream_wrapper (
36923692 model = parent_stream_config , config = config , ** kwargs
36933693 )
36943694 for parent_stream_config in model .parent_stream_configs
@@ -3701,7 +3701,7 @@ def create_substream_partition_router(
37013701 config = config ,
37023702 )
37033703
3704- def _create_message_repository_substream_wrapper (
3704+ def create_parent_stream_config_with_substream_wrapper (
37053705 self , model : ParentStreamConfigModel , config : Config , * , stream_name : str , ** kwargs : Any
37063706 ) -> Any :
37073707 # getting the parent state
0 commit comments