🔀 merge(base.py): merge changes from langfuse branch to base.py
🔀 merge(base.py): merge changes from langfuse branch to base.py to fix import and callback initialization
This commit is contained in:
parent
faa2a79c2b
commit
008dbd1237
1 changed files with 2 additions and 2 deletions
|
|
@ -27,11 +27,11 @@ def setup_callbacks(sync, trace_id, **kwargs):
|
||||||
|
|
||||||
|
|
||||||
def get_langfuse_callback(trace_id):
|
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
|
from langfuse.callback import CreateTrace
|
||||||
|
|
||||||
logger.debug("Initializing langfuse callback")
|
logger.debug("Initializing langfuse callback")
|
||||||
if langfuse := LangfuseInstance.get():
|
if langfuse := get_plugins_service().get("langfuse"):
|
||||||
logger.debug("Langfuse credentials found")
|
logger.debug("Langfuse credentials found")
|
||||||
try:
|
try:
|
||||||
trace = langfuse.trace(
|
trace = langfuse.trace(
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue