cleanup

Author: Kylejeong2

examples/integrations/temporal/src/research-activities.ts

@@ -284,7 +284,7 @@ export async function invalidateSession(sessionId: string): Promise<void> {
   const stagehand = activeSessions.get(sessionId);
   if (stagehand) {
     try {
-      await stagehand.page.close();
+      await stagehand.close();
     } catch (e) {
       // Ignore errors during invalidation
     }

examples/integrations/temporal/src/research-worker.ts

@@ -6,12 +6,12 @@ async function run() {
     workflowsPath: require.resolve('./workflows'),
     activities,
     taskQueue: 'browser-automation',
-    maxConcurrentActivityTaskExecutions: 2, // Limit concurrent browser sessions
+    maxConcurrentActivityTaskExecutions: 2, 
   });
 
   // Handle worker shutdown gracefully
   process.on('SIGINT', async () => {
-    await worker.shutdown();
+    worker.shutdown();
     process.exit(0);
   });
 

examples/integrations/temporal/src/workflows.ts

@@ -5,8 +5,6 @@ export async function searchWithRetry(query: string): Promise<string> {
   // Get workflow info to use in session ID generation
   const info = workflowInfo();
 
-  // Create different retry policies for different activity types
-  
   // Quick retry for initialization - might fail due to network
   const { initializeBrowser } = proxyActivities<typeof activities>({
     retry: {