gmakstutis/openrag
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

Add async method to retrieve connector by ID in LangflowConnectorService

Browse source 
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.
This commit is contained in:
Gabriel Luiz Freitas Almeida 2025-09-08 18:05:55 -03:00
parent 69c064763a
commit 762152934e
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/connectors/langflow_connector_service.py
View file

@ -288,3 +288,7 @@ class LangflowConnectorService:
) )
return task_id 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)