add flush

langfuse · Oct 9, 2023 · 420137b · 420137b
1 parent a22505a
commit 420137b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/langfuse/client.py b/langfuse/client.py
@@ -575,6 +575,7 @@ def link(self, observation: typing.Union[StatefulClient, str], run_name: str):
             observation.task_manager.flush()
             observation_id = observation.id
         elif isinstance(observation, str):
+            self.langfuse.flush()
             observation_id = observation
         else:
             raise ValueError("observation parameter must be either a StatefulClient or a string")