Add return type

airbytehq · Nov 13, 2024 · 0e17ad3 · 0e17ad3
1 parent 0bbfc52
commit 0e17ad3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py
@@ -341,7 +341,7 @@ def _remove_concurrent_streams_from_catalog(
     def _retriever_factory(
         self, stream_config: ComponentDefinition, source_config: Config, stream_state: StreamState
     ) -> Callable[[], Retriever]:
-        def _factory_method():
+        def _factory_method() -> Retriever:
             declarative_stream = self._constructor.create_component(
                 DeclarativeStreamModel,
                 stream_config,