in src/frontend_service/orchestrator/vertexai_function_calling/function_calling_orchestrator.py [0:0]
def close_clients(self):
close_client_tasks = [
asyncio.create_task(a.close()) for a in self._user_sessions.values()
]
asyncio.gather(*close_client_tasks)