fix function name (#132)

fix flush
langfuse · Oct 19, 2023 · 488218b · 488218b
1 parent ba7f40b
commit 488218b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/langfuse/client.py b/langfuse/client.py
@@ -558,7 +558,7 @@ def __init__(self, dataset_item: DatasetItem, langfuse: Langfuse):
 
         self.langfuse = langfuse
 
-    def link(self, observation: StatefulClient, run_name: str):
+    def flush(self, observation: StatefulClient, run_name: str):
         # flush the queue before creating the dataset run item
         # to ensure that all events are persistet.
         observation.task_manager.flush()