Skip to content

Commit 259bd4b

Browse files
authored
fix(flushing): flush interval to millis in SpanProcessor (#1244)
1 parent f497e9b commit 259bd4b

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

langfuse/_client/environment_variables.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@
8383
"""
8484
.. envvar:: LANGFUSE_FLUSH_INTERVAL
8585
86-
Max delay until a new ingestion batch is sent to the API.
86+
Max delay in seconds until a new ingestion batch is sent to the API.
8787
**Default value:** ``1``
8888
"""
8989

langfuse/_client/span_processor.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,9 @@ def __init__(
9393
span_exporter=langfuse_span_exporter,
9494
export_timeout_millis=timeout * 1_000 if timeout else None,
9595
max_export_batch_size=flush_at,
96-
schedule_delay_millis=flush_interval,
96+
schedule_delay_millis=flush_interval * 1_000
97+
if flush_interval is not None
98+
else None,
9799
)
98100

99101
def on_end(self, span: ReadableSpan) -> None:

0 commit comments

Comments
 (0)