diff --git a/src/backend/langflow/services/plugins/langfuse.py b/src/backend/langflow/services/plugins/langfuse.py index 29d59808b..7a1f60a48 100644 --- a/src/backend/langflow/services/plugins/langfuse.py +++ b/src/backend/langflow/services/plugins/langfuse.py @@ -17,23 +17,27 @@ class LangfuseInstance: @classmethod def create(cls): - logger.debug("Creating Langfuse instance") - from langfuse import Langfuse # type: ignore + try: + logger.debug("Creating Langfuse instance") + from langfuse import Langfuse # type: ignore - settings_manager = get_settings_service() + settings_manager = get_settings_service() - if ( - settings_manager.settings.LANGFUSE_PUBLIC_KEY - and settings_manager.settings.LANGFUSE_SECRET_KEY - ): - logger.debug("Langfuse credentials found") - cls._instance = Langfuse( - public_key=settings_manager.settings.LANGFUSE_PUBLIC_KEY, - secret_key=settings_manager.settings.LANGFUSE_SECRET_KEY, - host=settings_manager.settings.LANGFUSE_HOST, - ) - else: - logger.debug("No Langfuse credentials found") + if ( + settings_manager.settings.LANGFUSE_PUBLIC_KEY + and settings_manager.settings.LANGFUSE_SECRET_KEY + ): + logger.debug("Langfuse credentials found") + cls._instance = Langfuse( + public_key=settings_manager.settings.LANGFUSE_PUBLIC_KEY, + secret_key=settings_manager.settings.LANGFUSE_SECRET_KEY, + host=settings_manager.settings.LANGFUSE_HOST, + ) + else: + logger.debug("No Langfuse credentials found") + cls._instance = None + except ImportError: + logger.debug("Langfuse not installed") cls._instance = None @classmethod