Add return type

airbytehq · Nov 13, 2024 · 1ecc20d · 1ecc20d
1 parent 0e17ad3
commit 1ecc20d
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
@@ -342,7 +342,7 @@ def _retriever_factory(
         self, stream_config: ComponentDefinition, source_config: Config, stream_state: StreamState
     ) -> Callable[[], Retriever]:
         def _factory_method() -> Retriever:
-            declarative_stream = self._constructor.create_component(
+            declarative_stream: DeclarativeStream = self._constructor.create_component(
                 DeclarativeStreamModel,
                 stream_config,
                 source_config,