🔧 chore(base.py): add debug log messages for langfuse callback initialization and credentials check
🔧 chore(base.py): add debug log message for langfuse callback loaded
This commit is contained in:
parent
6fe486b164
commit
73f02439b0
1 changed files with 7 additions and 1 deletions
|
|
@ -17,6 +17,7 @@ def setup_callbacks(sync, **kwargs):
|
||||||
callbacks.append(AsyncStreamingLLMCallbackHandler(**kwargs))
|
callbacks.append(AsyncStreamingLLMCallbackHandler(**kwargs))
|
||||||
|
|
||||||
if langfuse_callback := get_langfuse_callback():
|
if langfuse_callback := get_langfuse_callback():
|
||||||
|
logger.debug("Langfuse callback loaded")
|
||||||
callbacks.append(langfuse_callback)
|
callbacks.append(langfuse_callback)
|
||||||
return callbacks
|
return callbacks
|
||||||
|
|
||||||
|
|
@ -24,13 +25,18 @@ def setup_callbacks(sync, **kwargs):
|
||||||
def get_langfuse_callback():
|
def get_langfuse_callback():
|
||||||
from langflow.settings import settings
|
from langflow.settings import settings
|
||||||
|
|
||||||
|
logger.debug("Initializing langfuse callback")
|
||||||
if settings.LANGFUSE_PUBLIC_KEY and settings.LANGFUSE_SECRET_KEY:
|
if settings.LANGFUSE_PUBLIC_KEY and settings.LANGFUSE_SECRET_KEY:
|
||||||
|
logger.debug("Langfuse credentials found")
|
||||||
try:
|
try:
|
||||||
from langfuse.callback import CallbackHandler
|
from langfuse.callback import CallbackHandler
|
||||||
|
|
||||||
return CallbackHandler(
|
return CallbackHandler(
|
||||||
settings.LANGFUSE_PUBLIC_KEY, settings.LANGFUSE_SECRET_KEY
|
public_key=settings.LANGFUSE_PUBLIC_KEY,
|
||||||
|
secret_key=settings.LANGFUSE_SECRET_KEY,
|
||||||
|
host=settings.LANGFUSE_HOST,
|
||||||
)
|
)
|
||||||
|
|
||||||
except Exception as exc:
|
except Exception as exc:
|
||||||
logger.error(f"Error initializing langfuse callback: {exc}")
|
logger.error(f"Error initializing langfuse callback: {exc}")
|
||||||
return None
|
return None
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue