From 762152934e3a0953eee9b6ae1de1fec3d25ce466 Mon Sep 17 00:00:00 2001 From: Gabriel Luiz Freitas Almeida Date: Mon, 8 Sep 2025 18:05:55 -0300 Subject: [PATCH] Add async method to retrieve connector by ID in LangflowConnectorService This commit introduces the _get_connector method in the LangflowConnectorService class, providing an asynchronous way to retrieve a connector by its connection ID. This addition enhances the service's functionality and aligns with the ongoing improvements in asynchronous processing and code maintainability. --- src/connectors/langflow_connector_service.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/connectors/langflow_connector_service.py b/src/connectors/langflow_connector_service.py index fa82eee7..52f0a6b8 100644 --- a/src/connectors/langflow_connector_service.py +++ b/src/connectors/langflow_connector_service.py @@ -288,3 +288,7 @@ class LangflowConnectorService: ) return task_id + + async def _get_connector(self, connection_id: str) -> Optional[BaseConnector]: + """Get a connector by connection ID (alias for get_connector)""" + return await self.get_connector(connection_id)