From eace769312594b824c39c75f5aeb66a70b483d0c Mon Sep 17 00:00:00 2001 From: Hassieb Pakzad <68423100+hassiebp@users.noreply.github.com> Date: Fri, 27 Jun 2025 12:18:31 +0200 Subject: [PATCH] fix(flushing): rely on OTEL default flush settings --- langfuse/_client/span_processor.py | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/langfuse/_client/span_processor.py b/langfuse/_client/span_processor.py index 8dcb78fea..0e0a92f98 100644 --- a/langfuse/_client/span_processor.py +++ b/langfuse/_client/span_processor.py @@ -63,9 +63,15 @@ def __init__( if blocked_instrumentation_scopes is not None else [] ) - flush_at = flush_at or int(os.environ.get(LANGFUSE_FLUSH_AT, 15)) - flush_interval = flush_interval or float( - os.environ.get(LANGFUSE_FLUSH_INTERVAL, 0.5) + + env_flush_at = os.environ.get(LANGFUSE_FLUSH_AT, None) + flush_at = flush_at or int(env_flush_at) if env_flush_at is not None else None + + env_flush_interval = os.environ.get(LANGFUSE_FLUSH_INTERVAL, None) + flush_interval = ( + flush_interval or float(env_flush_interval) + if env_flush_interval is not None + else None ) basic_auth_header = "Basic " + base64.b64encode(