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(