diff --git a/litellm/integrations/langfuse.py b/litellm/integrations/langfuse.py index efb5b29fe3..7c7f157940 100644 --- a/litellm/integrations/langfuse.py +++ b/litellm/integrations/langfuse.py @@ -33,6 +33,7 @@ class LangFuseLogger: host=self.langfuse_host, release=self.langfuse_release, debug=self.langfuse_debug, + flush_interval=1, # flush interval in seconds ) if os.getenv("UPSTREAM_LANGFUSE_SECRET_KEY") is not None: @@ -147,8 +148,6 @@ class LangFuseLogger: input, response_obj, ) - - self.Langfuse.flush() print_verbose( f"Langfuse Layer Logging - final response object: {response_obj}" )