From 50bc3b3d20b897de64732a6174790eafa2cabeeb Mon Sep 17 00:00:00 2001
From: Akira Hayashi <akira.hayashi@route06.co.jp>
Date: Fri, 18 Oct 2024 19:44:41 +0900
Subject: [PATCH] Add logs

---
 .../p/[agentId]/beta-proto/graph/server-actions.ts           | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/app/(playground)/p/[agentId]/beta-proto/graph/server-actions.ts b/app/(playground)/p/[agentId]/beta-proto/graph/server-actions.ts
index 8a4faaf0..bcd1b284 100644
--- a/app/(playground)/p/[agentId]/beta-proto/graph/server-actions.ts
+++ b/app/(playground)/p/[agentId]/beta-proto/graph/server-actions.ts
@@ -27,6 +27,7 @@ const flushMetricsAndShutdown = async (lf: Langfuse, metricReader: any) => {
 			reject(new Error("Metric flush timeout after 20 seconds"));
 		}, 20000);
 
+                console.log("inside waitUntil()-----")
 		Promise.all([metricReader.forceFlush(), lf.shutdownAsync()])
 			.then(() => {
 				clearTimeout(timeoutId);
@@ -75,6 +76,7 @@ export async function generateArtifactStream(
 					subscriptionId,
 					isR06User,
 				});
+                          console.log("before waitUntil()-----")
 				waitUntil(
 					flushMetricsAndShutdown(lf, metricReader).catch((error) => {
 						if (error.message === "Metric flush timeout after 20 seconds") {
@@ -90,6 +92,7 @@ export async function generateArtifactStream(
 						}
 					}),
 				);
+                          console.log("after waitUntil()-----")
 				generation.end({
 					output: result,
 				});
@@ -105,6 +108,8 @@ export async function generateArtifactStream(
 		stream.done();
 	})();
 
+        console.log("before return-----")
+
 	return { object: stream.value };
 }