From 008dbd1237aadacfbe892e725465141e8c5531e9 Mon Sep 17 00:00:00 2001 From: Gabriel Luiz Freitas Almeida Date: Thu, 2 Nov 2023 16:51:40 -0300 Subject: [PATCH] =?UTF-8?q?=F0=9F=94=80=20merge(base.py):=20merge=20change?= =?UTF-8?q?s=20from=20langfuse=20branch=20to=20base.py=20=F0=9F=94=80=20me?= =?UTF-8?q?rge(base.py):=20merge=20changes=20from=20langfuse=20branch=20to?= =?UTF-8?q?=20base.py=20to=20fix=20import=20and=20callback=20initializatio?= =?UTF-8?q?n?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/backend/langflow/processing/base.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/backend/langflow/processing/base.py b/src/backend/langflow/processing/base.py index 6c56a59dd..112dfd1fe 100644 --- a/src/backend/langflow/processing/base.py +++ b/src/backend/langflow/processing/base.py @@ -27,11 +27,11 @@ def setup_callbacks(sync, trace_id, **kwargs): def get_langfuse_callback(trace_id): - from langflow.services.plugins.langfuse import LangfuseInstance + from langflow.services.getters import get_plugins_service from langfuse.callback import CreateTrace logger.debug("Initializing langfuse callback") - if langfuse := LangfuseInstance.get(): + if langfuse := get_plugins_service().get("langfuse"): logger.debug("Langfuse credentials found") try: trace = langfuse.trace(